com.caucho.amqp.marshal
Class AmqpEnvelopeEncoder
java.lang.Object
com.caucho.amqp.marshal.AbstractMessageEncoder<AmqpEnvelope>
com.caucho.amqp.marshal.AmqpEnvelopeEncoder
- All Implemented Interfaces:
- AmqpMessageEncoder<AmqpEnvelope>
public class AmqpEnvelopeEncoder
- extends AbstractMessageEncoder<AmqpEnvelope>
- implements AmqpMessageEncoder<AmqpEnvelope>
Encodes a message as an envelope.
Method Summary |
protected void |
encodeApplicationProperties(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
void |
encodeData(AmqpWriter out,
AmqpEnvelope envelope)
|
protected void |
encodeDeliveryAnnotations(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected void |
encodeFooters(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected void |
encodeMessageAnnotations(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected void |
encodeProperties(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getContentEncoding(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
java.lang.String |
getContentType(AmqpEnvelope value)
|
protected java.lang.String |
getContentType(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.Object |
getCorrelationId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected long |
getCreationTime(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected long |
getExpiryTime(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getGroupId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected long |
getGroupSequence(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.Object |
getMessageId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getReplyTo(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getReplyToGroupId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getSubject(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getTo(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
protected java.lang.String |
getUserId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ENCODER
public static final AmqpEnvelopeEncoder ENCODER
AmqpEnvelopeEncoder
public AmqpEnvelopeEncoder()
encodeDeliveryAnnotations
protected void encodeDeliveryAnnotations(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
throws java.io.IOException
- Overrides:
encodeDeliveryAnnotations
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException
encodeMessageAnnotations
protected void encodeMessageAnnotations(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
throws java.io.IOException
- Overrides:
encodeMessageAnnotations
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException
getMessageId
protected java.lang.Object getMessageId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getUserId
protected java.lang.String getUserId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getTo
protected java.lang.String getTo(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getSubject
protected java.lang.String getSubject(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getReplyTo
protected java.lang.String getReplyTo(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getCorrelationId
protected java.lang.Object getCorrelationId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getContentType
protected java.lang.String getContentType(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getContentEncoding
protected java.lang.String getContentEncoding(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getExpiryTime
protected long getExpiryTime(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getCreationTime
protected long getCreationTime(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getGroupId
protected java.lang.String getGroupId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getGroupSequence
protected long getGroupSequence(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getReplyToGroupId
protected java.lang.String getReplyToGroupId(MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
getContentType
public java.lang.String getContentType(AmqpEnvelope value)
- Specified by:
getContentType
in interface AmqpMessageEncoder<AmqpEnvelope>
- Overrides:
getContentType
in class AbstractMessageEncoder<AmqpEnvelope>
encodeProperties
protected void encodeProperties(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
throws java.io.IOException
- Overrides:
encodeProperties
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException
encodeApplicationProperties
protected void encodeApplicationProperties(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
throws java.io.IOException
- Overrides:
encodeApplicationProperties
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException
encodeData
public void encodeData(AmqpWriter out,
AmqpEnvelope envelope)
throws java.io.IOException
- Specified by:
encodeData
in interface AmqpMessageEncoder<AmqpEnvelope>
- Specified by:
encodeData
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException
encodeFooters
protected void encodeFooters(AmqpWriter out,
MessagePropertiesFactory<AmqpEnvelope> factory,
AmqpEnvelope envelope)
throws java.io.IOException
- Overrides:
encodeFooters
in class AbstractMessageEncoder<AmqpEnvelope>
- Throws:
java.io.IOException