org.jboss.messaging.core.impl.postoffice
Class ReplicateDeliveryMessage

java.lang.Object
  extended by org.jboss.messaging.core.impl.postoffice.ReplicateDeliveryMessage
All Implemented Interfaces:
Streamable

public class ReplicateDeliveryMessage
extends java.lang.Object

Version:
$Revision: $6 Jul 2007 $Id: $
Author:
Tim Fox

Field Summary
static int ACK_ALL_REPLICATED_DELIVERIES_REQUEST
           
static int ADD_ALL_REPLICATED_DELIVERIES_REQUEST
           
static int BIND_REQUEST
           
static int GET_REPLICATED_DELIVERIES_REQUEST
           
static int JOIN_CLUSTER_REQUEST
           
static int LEAVE_CLUSTER_REQUEST
           
static int MESSAGE_REQUEST
           
protected static int NOT_NULL
           
protected static int NULL
           
static int PUT_REPLICANT_REQUEST
           
static int REMOVE_REPLICANT_REQUEST
           
static int REPLICATE_ACK_REQUEST
           
static int REPLICATE_DELIVERY_ACK_REQUEST
           
static int REPLICATE_DELIVERY_REQUEST
           
static int UNBIND_REQUEST
           
 
Constructor Summary
ReplicateDeliveryMessage()
           
ReplicateDeliveryMessage(int nodeID, java.lang.String queueName, java.lang.String sessionID, long messageID, long deliveryID, Address returnAddress)
           
 
Method Summary
 void read(java.io.DataInputStream in)
           
 void write(java.io.DataOutputStream out)
           
static void writeToStream(java.io.DataOutputStream daos, org.jboss.messaging.core.impl.postoffice.ClusterRequest request)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

JOIN_CLUSTER_REQUEST

public static final int JOIN_CLUSTER_REQUEST
See Also:
Constant Field Values

LEAVE_CLUSTER_REQUEST

public static final int LEAVE_CLUSTER_REQUEST
See Also:
Constant Field Values

BIND_REQUEST

public static final int BIND_REQUEST
See Also:
Constant Field Values

UNBIND_REQUEST

public static final int UNBIND_REQUEST
See Also:
Constant Field Values

MESSAGE_REQUEST

public static final int MESSAGE_REQUEST
See Also:
Constant Field Values

PUT_REPLICANT_REQUEST

public static final int PUT_REPLICANT_REQUEST
See Also:
Constant Field Values

REMOVE_REPLICANT_REQUEST

public static final int REMOVE_REPLICANT_REQUEST
See Also:
Constant Field Values

REPLICATE_DELIVERY_REQUEST

public static final int REPLICATE_DELIVERY_REQUEST
See Also:
Constant Field Values

REPLICATE_DELIVERY_ACK_REQUEST

public static final int REPLICATE_DELIVERY_ACK_REQUEST
See Also:
Constant Field Values

REPLICATE_ACK_REQUEST

public static final int REPLICATE_ACK_REQUEST
See Also:
Constant Field Values

ACK_ALL_REPLICATED_DELIVERIES_REQUEST

public static final int ACK_ALL_REPLICATED_DELIVERIES_REQUEST
See Also:
Constant Field Values

ADD_ALL_REPLICATED_DELIVERIES_REQUEST

public static final int ADD_ALL_REPLICATED_DELIVERIES_REQUEST
See Also:
Constant Field Values

GET_REPLICATED_DELIVERIES_REQUEST

public static final int GET_REPLICATED_DELIVERIES_REQUEST
See Also:
Constant Field Values

NULL

protected static final int NULL
See Also:
Constant Field Values

NOT_NULL

protected static final int NOT_NULL
See Also:
Constant Field Values
Constructor Detail

ReplicateDeliveryMessage

public ReplicateDeliveryMessage()

ReplicateDeliveryMessage

public ReplicateDeliveryMessage(int nodeID,
                                java.lang.String queueName,
                                java.lang.String sessionID,
                                long messageID,
                                long deliveryID,
                                Address returnAddress)
Method Detail

read

public void read(java.io.DataInputStream in)
          throws java.lang.Exception
Throws:
java.lang.Exception

write

public void write(java.io.DataOutputStream out)
           throws java.lang.Exception
Throws:
java.lang.Exception

writeToStream

public static void writeToStream(java.io.DataOutputStream daos,
                                 org.jboss.messaging.core.impl.postoffice.ClusterRequest request)
                          throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.