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.

Field Summary

Fields

Modifier and Type	Field and Description
static AmqpEnvelopeEncoder	ENCODER

Constructor Summary

Constructors

Constructor and Description
AmqpEnvelopeEncoder()

Method Summary

Modifier and Type	Method and Description
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 com.caucho.amqp.marshal.AbstractMessageEncoder

encode, getPriority, getTimeToLive, isDurable, isFirstAcquirer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.caucho.amqp.marshal.AmqpMessageEncoder

encode, getPriority, getTimeToLive, isDurable, isFirstAcquirer

Field Detail

ENCODER

public static final AmqpEnvelopeEncoder ENCODER

Constructor Detail

AmqpEnvelopeEncoder

public AmqpEnvelopeEncoder()

Method Detail

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