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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddestory()BlockingQueue<org.apache.synapse.MessageContext>getQueue()SEDAQueuePolicygetQueuePolicy()voidinit()booleanisInitialized()voidsetInitialized(boolean initialized)
-
-
-
Constructor Detail
-
SEDAQueue
public SEDAQueue(SEDAQueuePolicy queuePolicy, SEDAQueueConsumerWorkerFactory workerFactory)
-
-
Method Detail
-
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()
-
-