org.apache.camel.component.jms
Class JmsProducer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultProducer
org.apache.camel.impl.DefaultAsyncProducer
org.apache.camel.component.jms.JmsProducer
- All Implemented Interfaces:
- org.apache.camel.AsyncProcessor, org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class JmsProducer
- extends org.apache.camel.impl.DefaultAsyncProducer
- Version:
Fields inherited from class org.apache.camel.impl.DefaultProducer |
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultAsyncProducer |
process |
Methods inherited from class org.apache.camel.impl.DefaultProducer |
createExchange, createExchange, createExchange, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
JmsProducer
public JmsProducer(JmsEndpoint endpoint)
getEndpoint
public JmsEndpoint getEndpoint()
- Specified by:
getEndpoint
in interface org.apache.camel.Producer
- Overrides:
getEndpoint
in class org.apache.camel.impl.DefaultProducer
initReplyManager
protected void initReplyManager()
unInitReplyManager
protected void unInitReplyManager()
process
public boolean process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
processInOut
protected boolean processInOut(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
determineCorrelationId
protected String determineCorrelationId(javax.jms.Message message,
String provisionalCorrelationId)
throws javax.jms.JMSException
- Strategy to determine which correlation id to use among JMSMessageID and JMSCorrelationID.
- Parameters:
message
- the JMS messageprovisionalCorrelationId
- an optional provisional correlation id, which is preferred to be used
- Returns:
- the correlation id to use
- Throws:
javax.jms.JMSException
- can be thrown
processInOnly
protected boolean processInOnly(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
doSend
protected void doSend(boolean inOut,
String destinationName,
javax.jms.Destination destination,
org.springframework.jms.core.MessageCreator messageCreator,
MessageSentCallback callback)
- Sends the message using the JmsTemplate.
- Parameters:
inOut
- use inOut or inOnly templatedestinationName
- the destination namedestination
- the destination (if no name provided)messageCreator
- the creator to create the Message
to sendcallback
- optional callback to invoke when message has been sent
setMessageId
protected void setMessageId(org.apache.camel.Exchange exchange)
getInOnlyTemplate
public org.springframework.jms.core.JmsOperations getInOnlyTemplate()
setInOnlyTemplate
public void setInOnlyTemplate(org.springframework.jms.core.JmsOperations inOnlyTemplate)
getInOutTemplate
public org.springframework.jms.core.JmsOperations getInOutTemplate()
setInOutTemplate
public void setInOutTemplate(org.springframework.jms.core.JmsOperations inOutTemplate)
getUuidGenerator
public org.apache.camel.spi.UuidGenerator getUuidGenerator()
setUuidGenerator
public void setUuidGenerator(org.apache.camel.spi.UuidGenerator uuidGenerator)
testConnectionOnStartup
protected void testConnectionOnStartup()
throws org.apache.camel.FailedToCreateProducerException
- Pre tests the connection before starting the listening.
In case of connection failure the exception is thrown which prevents Camel from starting.
- Throws:
org.apache.camel.FailedToCreateProducerException
- is thrown if testing the connection failed
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultProducer
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class org.apache.camel.impl.DefaultProducer
- Throws:
Exception
createReplyManager
protected ReplyManager createReplyManager()
throws Exception
- Throws:
Exception
createReplyManager
protected ReplyManager createReplyManager(String replyTo)
throws Exception
- Throws:
Exception
Apache CAMEL