com.caucho.amqp.marshal
Class AmqpEnvelopeEncoder

java.lang.Object
  extended by com.caucho.amqp.marshal.AbstractMessageEncoder<AmqpEnvelope>
      extended by 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
static AmqpEnvelopeEncoder ENCODER
           
 
Constructor Summary
AmqpEnvelopeEncoder()
           
 
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 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