|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.util.EventObject
org.objectweb.proactive.core.event.ProActiveEvent
org.objectweb.proactive.core.event.MessageEvent
A MessageEvent
occurs when a Message
get sent or received or
when the treatment of a request begins or ends.
Message
,
Serialized FormField Summary | |
protected UniqueID |
destinationID
|
static int |
REPLY_RECEIVED
constant indicating the encapsulated message has been received |
static int |
REPLY_SENT
constant indicating the encapsulated message has been sent |
static int |
REQUEST_RECEIVED
constant indicating the encapsulated message has been received |
static int |
REQUEST_SENT
constant indicating the encapsulated message has been sent |
protected int |
requestQueueLength
Length of the request queue of the body that sends this event or -1 if this message did not affect the request queue length. |
static int |
SERVING_STARTED
constant indicating that the serving of the encapsulated request has started |
static int |
VOID_REQUEST_SERVED
constant indicating the encapsulated request without reply has been served |
Fields inherited from class org.objectweb.proactive.core.event.ProActiveEvent |
GENERIC_TYPE, timeStamp, type |
Fields inherited from class java.util.EventObject |
source |
Constructor Summary | |
MessageEvent(Message message,
int messageActionType,
UniqueID destinationID,
int requestQueueLength)
Creates a new MessageEvent based on the message
message and on the given action |
Method Summary | |
UniqueID |
getDestinationBodyID()
Returns the id of the body receiver of the encapsulated message. |
FTManager |
getFTManager()
Return the FTManager that have to treat this message |
MessageInfo |
getMessageInfo()
Returns fault-tolerance infos piggybacked on this message |
java.lang.String |
getMethodName()
Returns the method name of the method call packed in this message |
int |
getRequestQueueLength()
Returns the length of the request queue of the sending body or -1. |
long |
getSequenceNumber()
Returns a unique sequence number of this message |
UniqueID |
getSourceBodyID()
Returns the id of the body source of this message |
boolean |
ignoreIt()
Return true if this message must be ignored by the receiver |
boolean |
isOneWay()
Returns true if the message will not generate a response message |
void |
setFTManager(FTManager ft)
Set the FTManager that have to treat this message |
void |
setIgnoreIt(boolean ignore)
Set or unset the ignore tag. |
void |
setMessageInfo(MessageInfo mi)
Set fault-tolerance infos piggybacked on this message |
java.lang.String |
toString()
Returns a string representation of this event |
boolean |
wasSent()
|
Methods inherited from class org.objectweb.proactive.core.event.ProActiveEvent |
getTimeStamp, getType |
Methods inherited from class java.util.EventObject |
getSource |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.objectweb.proactive.core.body.message.Message |
getTimeStamp |
Field Detail |
public static final int REQUEST_SENT
public static final int REQUEST_RECEIVED
public static final int REPLY_SENT
public static final int REPLY_RECEIVED
public static final int VOID_REQUEST_SERVED
public static final int SERVING_STARTED
protected UniqueID destinationID
protected int requestQueueLength
Constructor Detail |
public MessageEvent(Message message, int messageActionType, UniqueID destinationID, int requestQueueLength)
MessageEvent
based on the message
message
and on the given action
message
- the message on which this event is based.messageActionType
- the type of the action occuring with
this message either REQUEST_SENT/RECEIVED, REPLY_SENT/RECEIVED,
VOID_REQUEST_SERVED or SERVING_STARTED.requestQueueLength
- the length of the request queue of the
body that sends this event or -1 if this event did not affect the queue length.Method Detail |
public UniqueID getDestinationBodyID()
public int getRequestQueueLength()
public java.lang.String toString()
toString
in class ProActiveEvent
public boolean wasSent()
public UniqueID getSourceBodyID()
Message
getSourceBodyID
in interface Message
public java.lang.String getMethodName()
Message
getMethodName
in interface Message
public long getSequenceNumber()
Message
getSequenceNumber
in interface Message
public boolean isOneWay()
Message
isOneWay
in interface Message
public MessageInfo getMessageInfo()
Message
getMessageInfo
in interface Message
public void setMessageInfo(MessageInfo mi)
Message
setMessageInfo
in interface Message
mi
- a MessageInfo object that contains fault-tolerance infospublic void setIgnoreIt(boolean ignore)
Message
setIgnoreIt
in interface Message
ignore
- true if this request must be ignored, false otherwise.public boolean ignoreIt()
Message
ignoreIt
in interface Message
public void setFTManager(FTManager ft)
Message
setFTManager
in interface Message
ft
- the FTManager that have to treat this messagepublic FTManager getFTManager()
Message
getFTManager
in interface Message
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |