Package fr.dyade.aaa.agent
Class SyncNotification
- java.lang.Object
-
- fr.dyade.aaa.agent.Notification
-
- fr.dyade.aaa.agent.SyncNotification
-
- All Implemented Interfaces:
Encodable,Serializable,Cloneable
- Direct Known Subclasses:
AdminSyncNotification,GetConnectionNot,GetProxyIdListNot,GetProxyIdNot,OpenConnectionNot
public class SyncNotification extends Notification
This notification is used to synchronously call a local agent from a collocated thread.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSyncNotification.Context(package private) static classSyncNotification.Result
-
Field Summary
Fields Modifier and Type Field Description private Threadcallerprivate SyncNotification.Contextctxprivate static longserialVersionUIDdefine serialVersionUID for interoperability-
Fields inherited from class fr.dyade.aaa.agent.Notification
deadNotificationAgentId, detachable, detached, expiration, messageId, persistent, priority
-
Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedSyncNotification()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ExceptiongetException()ObjectgetValue(int index)voidinterupt()Object[]invoke(AgentId to)Object[]invoke(AgentId to, long timeout)voidinvokeNoWait(AgentId to)voidReturn(Object[] values)voidThrow(Exception exc)voidwakeup()-
Methods inherited from class fr.dyade.aaa.agent.Notification
clone, decode, encode, getContext, getDeadNotificationAgentId, getEncodableClassId, getEncodedSize, getExpiration, getMessageId, getPriority, isPersistent, setContext, setDeadNotificationAgentId, setExpiration, setPriority, toString, toString
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
define serialVersionUID for interoperability- See Also:
- Constant Field Values
-
ctx
private transient SyncNotification.Context ctx
-
caller
private Thread caller
-
-
Method Detail
-
invokeNoWait
public void invokeNoWait(AgentId to) throws InterruptedException, Exception
- Throws:
InterruptedExceptionException
-
invoke
public Object[] invoke(AgentId to) throws InterruptedException, Exception
- Throws:
InterruptedExceptionException
-
invoke
public Object[] invoke(AgentId to, long timeout) throws InterruptedException, Exception
- Throws:
InterruptedExceptionException
-
interupt
public void interupt()
-
wakeup
public void wakeup()
-
Throw
public void Throw(Exception exc)
-
Return
public void Return(Object[] values)
-
getValue
public Object getValue(int index)
-
getException
public final Exception getException()
-
-