Package org.apache.synapse.experimental.mediators.seda

Class SEDAQueue

java.lang.Object

org.apache.synapse.experimental.mediators.seda.SEDAQueue

public class SEDAQueue
extends Object

Constructor Summary

Constructors

Constructor	Description
SEDAQueue(SEDAQueuePolicy queuePolicy, SEDAQueueConsumerWorkerFactory workerFactory)

Method Summary

Modifier and Type	Method	Description
void	destory()
BlockingQueue<org.apache.synapse.MessageContext>	getQueue()
SEDAQueuePolicy	getQueuePolicy()
void	init()
boolean	isInitialized()
void	setInitialized(boolean initialized)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SEDAQueue

public SEDAQueue(SEDAQueuePolicy queuePolicy,
 SEDAQueueConsumerWorkerFactory workerFactory)

Method Details

init

public void init()

destory

public void destory()

getQueue

public BlockingQueue<org.apache.synapse.MessageContext> getQueue()

isInitialized

public boolean isInitialized()

setInitialized

public void setInitialized(boolean initialized)

getQueuePolicy

public SEDAQueuePolicy getQueuePolicy()