org.jboss.messaging.core.remoting.impl.wireformat.replication
Class SessionReplicateDeliveryMessage
java.lang.Object
org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl
org.jboss.messaging.core.remoting.impl.wireformat.replication.SessionReplicateDeliveryMessage
- All Implemented Interfaces:
- Packet
public class SessionReplicateDeliveryMessage
- extends PacketImpl
- Version:
- $Revision$
- Author:
- Tim Fox
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 |
Methods inherited from class org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl |
decode, encode, getChannelID, getPacketSize, getParentString, getType, isResponse, isWriteAlways, nullableStringEncodeSize, setChannelID, stringEncodeSize, toString |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
SessionReplicateDeliveryMessage
public SessionReplicateDeliveryMessage(long consumerID,
long messageID)
SessionReplicateDeliveryMessage
public SessionReplicateDeliveryMessage()
getConsumerID
public long getConsumerID()
getMessageID
public long getMessageID()
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
isRequiresConfirmations
public boolean isRequiresConfirmations()
- Specified by:
isRequiresConfirmations
in interface Packet
- Overrides:
isRequiresConfirmations
in class PacketImpl
equals
public boolean equals(java.lang.Object other)
- Overrides:
equals
in class PacketImpl
Copyright © 2006 JBoss Inc. All Rights Reserved.