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 void
destory()
BlockingQueue<org.apache.synapse.MessageContext>
getQueue()
SEDAQueuePolicy
getQueuePolicy()
void
init()
boolean
isInitialized()
void
setInitialized(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()
-
-