public abstract class TOMSender extends java.lang.Object implements ReplyReceiver
Constructor and Description |
---|
TOMSender()
Creates a new instance of TOMulticastSender
TODO: This may really be empty?
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
generateOperationId() |
int |
generateRequestId(TOMMessageType type) |
CommunicationSystemClientSide |
getCommunicationSystem() |
int |
getProcessId() |
int |
getSession() |
ClientViewController |
getViewManager() |
void |
init(int processId)
This method initializes the object
TODO: Ask if this method cannot be protected (compiles, but....)
|
void |
init(int processId,
java.lang.String configHome) |
void |
sendMessageToTargets(byte[] m,
int reqId,
int[] targets,
TOMMessageType type) |
void |
sendMessageToTargets(byte[] m,
int reqId,
int operationId,
int[] targets,
TOMMessageType type) |
void |
TOMulticast(byte[] m,
int reqId,
int operationId,
TOMMessageType reqType) |
void |
TOMulticast(byte[] m,
int reqId,
TOMMessageType reqType)
Multicast data to the group of replicas
|
void |
TOMulticast(TOMMessage sm)
Multicast a TOMMessage to the group of replicas
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
replyReceived
public TOMSender()
public void close()
public CommunicationSystemClientSide getCommunicationSystem()
public ClientViewController getViewManager()
public void init(int processId)
processId
- ID of the processpublic void init(int processId, java.lang.String configHome)
public int getProcessId()
public int generateRequestId(TOMMessageType type)
public int generateOperationId()
public void TOMulticast(TOMMessage sm)
sm
- Message to be multicastpublic void TOMulticast(byte[] m, int reqId, TOMMessageType reqType)
m
- Data to be multicastreqId
- unique integer that identifies this requestreqType
- TOM_NORMAL, TOM_READONLY or TOM_RECONFIGURATIONpublic void TOMulticast(byte[] m, int reqId, int operationId, TOMMessageType reqType)
public void sendMessageToTargets(byte[] m, int reqId, int[] targets, TOMMessageType type)
public void sendMessageToTargets(byte[] m, int reqId, int operationId, int[] targets, TOMMessageType type)
public int getSession()