public class InOutProducer extends SjmsProducer
Modifier and Type | Class and Description |
---|---|
protected class |
InOutProducer.MessageConsumerResourcesFactory
A pool of
MessageConsumerResources objects that are the reply consumers. |
SjmsProducer.MessageProducerResourcesFactory
Constructor and Description |
---|
InOutProducer(SjmsEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageProducerResources |
doCreateProducerModel() |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.spi.UuidGenerator |
getUuidGenerator() |
void |
sendMessage(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
MessageProducerResources producer)
TODO time out is actually double as it waits for the producer and then
waits for the response.
|
void |
setUuidGenerator(org.apache.camel.spi.UuidGenerator uuidGenerator) |
getAcknowledgeMode, getCommitStrategy, getConnectionResource, getConsumerCount, getDestinationName, getEndpoint, getExecutor, getNamedReplyTo, getProducerCount, getProducers, getReplyTo, getResponseTimeOut, getTtl, isEndpointTransacted, isPersistent, isSynchronous, isTopic, process, setProducers
createExchange, createExchange, createExchange, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public InOutProducer(SjmsEndpoint endpoint)
public org.apache.camel.spi.UuidGenerator getUuidGenerator()
public void setUuidGenerator(org.apache.camel.spi.UuidGenerator uuidGenerator)
protected void doStart() throws Exception
doStart
in class SjmsProducer
Exception
protected void doStop() throws Exception
doStop
in class SjmsProducer
Exception
public MessageProducerResources doCreateProducerModel() throws Exception
doCreateProducerModel
in class SjmsProducer
Exception
public void sendMessage(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, MessageProducerResources producer) throws Exception
sendMessage
in class SjmsProducer
Exception
Apache Camel