public class AmqpJmsObjectMessageFacade extends AmqpJmsMessageFacade implements JmsObjectMessageFacade
connection, message
Constructor and Description |
---|
AmqpJmsObjectMessageFacade(AmqpConnection connection,
boolean isAmqpTypeEncoded)
Creates a new facade instance
|
AmqpJmsObjectMessageFacade(AmqpConsumer consumer,
org.apache.qpid.proton.message.Message message)
Creates a new Facade around an incoming AMQP Message for dispatch to the
JMS Consumer instance.
|
Modifier and Type | Method and Description |
---|---|
void |
clearBody()
Clears the contents of this Message.
|
AmqpJmsObjectMessageFacade |
copy()
Create a new instance and perform a deep copy of this object's
contents.
|
byte |
getJmsMsgType() |
Serializable |
getObject()
Gets the Object value that is contained in the provider message.
|
boolean |
isAmqpTypedEncoding() |
void |
onSend(long producerTtl)
Called before a message is sent to allow a Message instance to move the
contents from a logical data structure to a binary form for transmission, or
other processing such as setting proper message headers etc.
|
void |
setObject(Serializable value)
Stores the given object into the provider Message.
|
applicationPropertyExists, clearProperties, copyInto, getAmqpMessage, getAmqpTimeToLiveOverride, getApplicationProperty, getApplicationPropertyNames, getConnection, getContentType, getCorrelationId, getCorrelationIdBytes, getDeliveryCount, getDestination, getExpiration, getGroupId, getGroupSequence, getMessageId, getPriority, getProperty, getPropertyNames, getProviderMessageIdObject, getRedeliveryCount, getReplyTo, getReplyToGroupId, getTimestamp, getType, getUserId, getUserIdBytes, hasAmqpTimeToLiveOverride, isPersistent, isRedelivered, onDispatch, propertyExists, setAmqpTimeToLiveOverride, setApplicationProperty, setContentType, setCorrelationId, setCorrelationIdBytes, setDeliveryCount, setDestination, setExpiration, setGroupId, setGroupSequence, setMessageId, setPersistent, setPriority, setProperty, setProviderMessageIdObject, setRedelivered, setRedeliveryCount, setReplyTo, setReplyToGroupId, setTimestamp, setType, setUserId, setUserIdBytes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearProperties, getCorrelationId, getCorrelationIdBytes, getDeliveryCount, getDestination, getExpiration, getGroupId, getGroupSequence, getMessageId, getPriority, getProperty, getPropertyNames, getProviderMessageIdObject, getRedeliveryCount, getReplyTo, getTimestamp, getType, getUserId, getUserIdBytes, isPersistent, isRedelivered, onDispatch, propertyExists, setCorrelationId, setCorrelationIdBytes, setDeliveryCount, setDestination, setExpiration, setGroupId, setGroupSequence, setMessageId, setPersistent, setPriority, setProperty, setProviderMessageIdObject, setRedelivered, setRedeliveryCount, setReplyTo, setTimestamp, setType, setUserId, setUserIdBytes
public AmqpJmsObjectMessageFacade(AmqpConnection connection, boolean isAmqpTypeEncoded)
connection
- the AmqpConnection that under which this facade was created.isAmqpTypeEncoded
- controls the type used to encode the body.public AmqpJmsObjectMessageFacade(AmqpConsumer consumer, org.apache.qpid.proton.message.Message message)
consumer
- the consumer that received this message.message
- the incoming Message instance that is being wrapped.public byte getJmsMsgType()
getJmsMsgType
in class AmqpJmsMessageFacade
public boolean isAmqpTypedEncoding()
public AmqpJmsObjectMessageFacade copy() throws javax.jms.JMSException
JmsMessageFacade
copy
in interface JmsMessageFacade
copy
in interface JmsObjectMessageFacade
copy
in class AmqpJmsMessageFacade
javax.jms.JMSException
- if an error occurs while copying the message.public Serializable getObject() throws IOException, ClassNotFoundException
JmsObjectMessageFacade
getObject
in interface JmsObjectMessageFacade
IOException
- if the provider fails to get the object due to some internal error.ClassNotFoundException
- if object de-serialization fails because the ClassLoader
cannot find the Class locally.public void setObject(Serializable value) throws IOException
JmsObjectMessageFacade
setObject
in interface JmsObjectMessageFacade
value
- the new value to write to the provider message.IOException
- if the provider fails to store the object due to some internal error.public void clearBody()
JmsMessageFacade
clearBody
in interface JmsMessageFacade
clearBody
in class AmqpJmsMessageFacade
public void onSend(long producerTtl) throws javax.jms.JMSException
JmsMessageFacade
onSend
in interface JmsMessageFacade
onSend
in class AmqpJmsMessageFacade
producerTtl
- the time to live value configured on the producer when sent.javax.jms.JMSException
- if an error occurs while preparing the message for send.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.