public abstract class AbstractAMQMessageDelegate extends Object implements AMQMessageDelegate
Modifier | Constructor and Description |
---|---|
protected |
AbstractAMQMessageDelegate(long deliveryTag) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge() |
void |
acknowledgeThis() |
protected javax.jms.Destination |
convertToAddressBasedDestination(String exchange,
String routingKey,
String subject,
boolean useNodeTypeForDestinationType,
int type) |
protected static boolean |
exchangeMapContains(String exchange)
Accessor method to allow lookups of the given exchange name.
|
protected AMQDestination |
generateDestination(String exchange,
String routingKey)
Called when a Destination is requried.
|
AMQSession<?,?> |
getAMQSession() |
long |
getDeliveryTag()
Get the AMQ message number assigned to this message
|
void |
setAMQSession(AMQSession<?,?> s)
The session is set when CLIENT_ACKNOWLEDGE mode is used so that the CHANNEL ACK can be sent when the user calls
acknowledge()
|
protected static void |
updateExchangeType(String exchange,
String newtype)
Update the exchange name to type mapping.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearProperties, getBooleanProperty, getByteProperty, getContentType, getDoubleProperty, getEncoding, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getReplyToString, getShortProperty, getStringProperty, propertyExists, removeProperty, setBooleanProperty, setByteProperty, setContentType, setDoubleProperty, setEncoding, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSMessageID, setJMSPriority, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
protected AbstractAMQMessageDelegate(long deliveryTag)
public long getDeliveryTag()
getDeliveryTag
in interface AMQMessageDelegate
protected AMQDestination generateDestination(String exchange, String routingKey)
exchange
- The exchange nameroutingKey
- The routing key to be used for the Destinationprotected static void updateExchangeType(String exchange, String newtype)
exchange
- the name of the exchangenewtype
- the AMQP exchange class name i.e. directprotected static boolean exchangeMapContains(String exchange)
exchange
- the exchange name to lookuppublic void acknowledgeThis() throws javax.jms.JMSException
acknowledgeThis
in interface AMQMessageDelegate
javax.jms.JMSException
public void acknowledge() throws javax.jms.JMSException
acknowledge
in interface AMQMessageDelegate
javax.jms.JMSException
public void setAMQSession(AMQSession<?,?> s)
setAMQSession
in interface AMQMessageDelegate
s
- the AMQ session that delivered this messagepublic AMQSession<?,?> getAMQSession()
getAMQSession
in interface AMQMessageDelegate
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.