public class EndpointMessageListener extends Object implements org.springframework.jms.listener.SessionAwareMessageListener
MessageListener
which can be used to delegate processing to a
Camel endpoint.
Note that instance of this object has to be thread safe (reentrant)Constructor and Description |
---|
EndpointMessageListener(JmsEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
createExchange(javax.jms.Message message,
javax.jms.Session session,
Object replyDestination) |
protected String |
determineCorrelationId(javax.jms.Message message)
Strategy to determine which correlation id to use among JMSMessageID and JMSCorrelationID.
|
JmsBinding |
getBinding() |
Object |
getReplyToDestination() |
protected Object |
getReplyToDestination(javax.jms.Message message) |
org.springframework.jms.core.JmsOperations |
getTemplate() |
boolean |
isAsync() |
boolean |
isDisableReplyTo() |
boolean |
isEagerLoadingOfProperties() |
void |
onMessage(javax.jms.Message message,
javax.jms.Session session) |
protected void |
sendReply(javax.jms.Destination replyDestination,
javax.jms.Message message,
org.apache.camel.Exchange exchange,
org.apache.camel.Message out,
Exception cause) |
protected void |
sendReply(String replyDestination,
javax.jms.Message message,
org.apache.camel.Exchange exchange,
org.apache.camel.Message out,
Exception cause) |
void |
setAsync(boolean async)
Sets whether asynchronous routing is enabled.
|
void |
setBinding(JmsBinding binding)
Sets the binding used to convert from a Camel message to and from a JMS
message
|
void |
setDisableReplyTo(boolean disableReplyTo)
Allows the reply-to behaviour to be disabled
|
void |
setEagerLoadingOfProperties(boolean eagerLoadingOfProperties) |
void |
setReplyToDestination(Object replyToDestination)
Provides an explicit reply to destination which overrides
any incoming value of
Message.getJMSReplyTo() |
void |
setTemplate(org.springframework.jms.core.JmsOperations template) |
String |
toString() |
public EndpointMessageListener(JmsEndpoint endpoint, org.apache.camel.Processor processor)
public void onMessage(javax.jms.Message message, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener
javax.jms.JMSException
public org.apache.camel.Exchange createExchange(javax.jms.Message message, javax.jms.Session session, Object replyDestination)
public JmsBinding getBinding()
public void setBinding(JmsBinding binding)
binding
- the binding to usepublic boolean isEagerLoadingOfProperties()
public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
public org.springframework.jms.core.JmsOperations getTemplate()
public void setTemplate(org.springframework.jms.core.JmsOperations template)
public boolean isDisableReplyTo()
public void setDisableReplyTo(boolean disableReplyTo)
public Object getReplyToDestination()
public void setReplyToDestination(Object replyToDestination)
Message.getJMSReplyTo()
replyToDestination
- the destination that should be used to send replies to
as either a String or Destination
type.public boolean isAsync()
public void setAsync(boolean async)
Exchange
asynchronous.protected String determineCorrelationId(javax.jms.Message message) throws javax.jms.JMSException
message
- the JMS messagejavax.jms.JMSException
- can be thrownprotected void sendReply(javax.jms.Destination replyDestination, javax.jms.Message message, org.apache.camel.Exchange exchange, org.apache.camel.Message out, Exception cause)
protected void sendReply(String replyDestination, javax.jms.Message message, org.apache.camel.Exchange exchange, org.apache.camel.Message out, Exception cause)
protected Object getReplyToDestination(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
Apache Camel