org.jboss.messaging.core.remoting.impl.wireformat
Class SessionReceiveMessage

java.lang.Object
  extended by org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl
      extended by org.jboss.messaging.core.remoting.impl.wireformat.SessionReceiveMessage
All Implemented Interfaces:
Packet

public class SessionReceiveMessage
extends PacketImpl

Version:
$Revision$
Author:
Tim Fox, Ovidiu Feodorov, Jeff Mesnil

Field Summary
static int SESSION_RECEIVE_MESSAGE_LARGE_MESSAGE_SIZE
           
 
Fields inherited from class org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl
BASIC_PACKET_SIZE, CREATE_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, EARLY_RESPONSE, EXCEPTION, NULL_RESPONSE, PACKETS_CONFIRMED, PING, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATE_ACKNOWLEDGE, REPLICATE_ADD_REMOTE_CONSUMER, REPLICATE_ADD_REMOTE_QUEUE_BINDING, REPLICATE_CREATESESSION, REPLICATE_REDISTRIBUTION, REPLICATE_REMOVE_REMOTE_CONSUMER, REPLICATE_REMOVE_REMOTE_QUEUE_BINDING, REPLICATE_STARTUP_INFO, REPLICATION_RESPONSE, SESS_ACKNOWLEDGE, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_CLOSE, SESS_COMMIT, SESS_CONSUMER_CLOSE, SESS_CREATECONSUMER, SESS_EXPIRED, SESS_FAILOVER_COMPLETE, SESS_FLOWTOKEN, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_RECEIVE_CONTINUATION, SESS_RECEIVE_MSG, SESS_REPLICATE_DELIVERY, SESS_ROLLBACK, SESS_SEND, SESS_SEND_CONTINUATION, SESS_SEND_LARGE, SESS_START, SESS_STOP, SESS_XA_COMMIT, SESS_XA_END, SESS_XA_FORGET, SESS_XA_GET_TIMEOUT, SESS_XA_GET_TIMEOUT_RESP, SESS_XA_INDOUBT_XIDS, SESS_XA_INDOUBT_XIDS_RESP, SESS_XA_JOIN, SESS_XA_PREPARE, SESS_XA_RESP, SESS_XA_RESUME, SESS_XA_ROLLBACK, SESS_XA_SET_TIMEOUT, SESS_XA_SET_TIMEOUT_RESP, SESS_XA_START, SESS_XA_SUSPEND
 
Constructor Summary
SessionReceiveMessage()
           
SessionReceiveMessage(long consumerID, byte[] largeMessageHeader, long largeMessageSize, int deliveryCount)
           
SessionReceiveMessage(long consumerID, ServerMessage message, int deliveryCount)
           
 
Method Summary
 void decodeBody(MessagingBuffer buffer)
           
 void encodeBody(MessagingBuffer buffer)
           
 ClientMessageInternal getClientMessage()
           
 long getConsumerID()
           
 int getDeliveryCount()
           
 byte[] getLargeMessageHeader()
           
 long getLargeMessageSize()
           
 int getRequiredBufferSize()
           
 ServerMessage getServerMessage()
           
 boolean isLargeMessage()
           
 
Methods inherited from class org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl
decode, encode, equals, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, isWriteAlways, nullableStringEncodeSize, setChannelID, stringEncodeSize, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

SESSION_RECEIVE_MESSAGE_LARGE_MESSAGE_SIZE

public static final int SESSION_RECEIVE_MESSAGE_LARGE_MESSAGE_SIZE
See Also:
Constant Field Values
Constructor Detail

SessionReceiveMessage

public SessionReceiveMessage(long consumerID,
                             byte[] largeMessageHeader,
                             long largeMessageSize,
                             int deliveryCount)

SessionReceiveMessage

public SessionReceiveMessage(long consumerID,
                             ServerMessage message,
                             int deliveryCount)

SessionReceiveMessage

public SessionReceiveMessage()
Method Detail

getConsumerID

public long getConsumerID()

getClientMessage

public ClientMessageInternal getClientMessage()

getServerMessage

public ServerMessage getServerMessage()

getLargeMessageHeader

public byte[] getLargeMessageHeader()

isLargeMessage

public boolean isLargeMessage()
Returns:
the largeMessage

getDeliveryCount

public int getDeliveryCount()

getLargeMessageSize

public long getLargeMessageSize()
Returns:
the largeMessageSize

getRequiredBufferSize

public int getRequiredBufferSize()
Specified by:
getRequiredBufferSize in interface Packet
Overrides:
getRequiredBufferSize in class PacketImpl

encodeBody

public void encodeBody(MessagingBuffer buffer)
Overrides:
encodeBody in class PacketImpl

decodeBody

public void decodeBody(MessagingBuffer buffer)
Overrides:
decodeBody in class PacketImpl


Copyright © 2006 JBoss Inc. All Rights Reserved.