com.cloudtran.replicator.manager
Class ReplicatorManagerSide

java.lang.Object
  extended by com.cloudtran.replicator.manager.ReplicatorManagerSide

public class ReplicatorManagerSide
extends Object

This is the main class for the replicator.


Field Summary
static String LOCALSTORE_ZONE
           
 
Constructor Summary
ReplicatorManagerSide()
           
 
Method Summary
static void addOutboundQueueEntry(Object oqe)
          Puts a ReplicatorPacket or command onto the outbound queue
static int getOutboundQueueSize()
           
static Object pollOutboundMessage()
           
static Object takeOutboundMessage()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOCALSTORE_ZONE

public static String LOCALSTORE_ZONE
Constructor Detail

ReplicatorManagerSide

public ReplicatorManagerSide()
Method Detail

addOutboundQueueEntry

public static void addOutboundQueueEntry(Object oqe)
Puts a ReplicatorPacket or command onto the outbound queue

Parameters:
oqe - The outbound queue entry

takeOutboundMessage

public static Object takeOutboundMessage()
                                  throws InterruptedException
Throws:
InterruptedException

pollOutboundMessage

public static Object pollOutboundMessage()

getOutboundQueueSize

public static int getOutboundQueueSize()