|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultProducer org.apache.camel.impl.DefaultAsyncProducer org.apache.camel.component.sjms.SjmsProducer org.apache.camel.component.sjms.producer.InOutProducer
public class InOutProducer
A Camel Producer that provides the InOut Exchange pattern.
Nested Class Summary | |
---|---|
protected class |
InOutProducer.InternalTempDestinationListener
|
protected class |
InOutProducer.MessageConsumerPool
A pool of InOutProducer.MessageConsumerResource objects that are the reply
consumers. |
protected class |
InOutProducer.MessageConsumerResource
TODO Add Class documentation for MessageConsumerResource |
Nested classes/interfaces inherited from class org.apache.camel.component.sjms.SjmsProducer |
---|
SjmsProducer.MessageProducerPool, SjmsProducer.MessageProducerResources |
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.DefaultProducer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
InOutProducer(SjmsEndpoint endpoint)
|
Method Summary | |
---|---|
SjmsProducer.MessageProducerResources |
doCreateProducerModel()
|
protected void |
doStart()
|
protected void |
doStop()
|
InOutProducer.MessageConsumerPool |
getConsumers()
|
void |
sendMessage(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
TODO time out is actually double as it waits for the producer and then waits for the response. |
void |
setConsumers(InOutProducer.MessageConsumerPool consumers)
|
Methods inherited from class org.apache.camel.component.sjms.SjmsProducer |
---|
getAcknowledgeMode, getCommitStrategy, getConnectionResource, getConsumerCount, getDestinationName, getExecutor, getNamedReplyTo, getProducerCount, getProducers, getReplyTo, getResponseTimeOut, getSjmsEndpoint, getTtl, isEndpointTransacted, isPersistent, isSynchronous, isTopic, process, setProducers |
Methods inherited from class org.apache.camel.impl.DefaultAsyncProducer |
---|
process |
Methods inherited from class org.apache.camel.impl.DefaultProducer |
---|
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
public InOutProducer(SjmsEndpoint endpoint)
Method Detail |
---|
protected void doStart() throws Exception
doStart
in class SjmsProducer
Exception
protected void doStop() throws Exception
doStop
in class SjmsProducer
Exception
public SjmsProducer.MessageProducerResources doCreateProducerModel() throws Exception
doCreateProducerModel
in class SjmsProducer
Exception
public void sendMessage(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback) throws Exception
sendMessage
in class SjmsProducer
exchange
- callback
-
Exception
SjmsProducer.sendMessage(org.apache.camel.Exchange,
org.apache.camel.AsyncCallback)
public void setConsumers(InOutProducer.MessageConsumerPool consumers)
public InOutProducer.MessageConsumerPool getConsumers()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |