|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.proxies.ProxyImpl
The ProxyImpl
class implements the MOM proxy behaviour,
basically forwarding client requests to MOM destinations and MOM
destinations replies to clients.
Constructor Summary | |
ProxyImpl(ProxyAgentItf proxyAgent)
Constructs a ProxyImpl instance. |
Method Summary | |
void |
deleteProxy(AgentId from)
This method deletes the proxy by notifying its connected clients, denying the non acknowledged messages, deleting the temporary destinations, removing the subscriptions. |
AgentId |
getId()
|
void |
initialize(boolean firstTime)
(Re)initializes the proxy. |
void |
react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions. |
void |
reactToClientRequest(int key,
AbstractJmsRequest request)
Method processing clients requests. |
void |
readBag(java.io.ObjectInputStream in)
|
java.lang.String |
toString()
|
void |
writeBag(java.io.ObjectOutputStream out)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public ProxyImpl(ProxyAgentItf proxyAgent)
ProxyImpl
instance.
Method Detail |
public java.lang.String toString()
public void initialize(boolean firstTime) throws java.lang.Exception
java.lang.Exception
- If the proxy state could not be fully retrieved,
leading to an inconsistent state.public void reactToClientRequest(int key, AbstractJmsRequest request)
Some of the client requests are directly forwarded, some others are sent to the proxy so that their processing occurs in a transaction.
A MomExceptionReply
wrapping a DestinationException
might be sent back if a target destination can't be identified.
public void react(AgentId from, Notification not) throws UnknownNotificationException
A JMS proxy reacts to:
SyncReply
proxy synchronizing notification,SetDMQRequest
admin notification,SetThreshRequest
admin notification,Monit_GetDMQSettings
monitoring notification,AbstractReply
destination replies,AdminReply
administration replies,fr.dyade.aaa.agent.UnknownAgent
.
UnknownNotificationException
- If the notification is not
expected.public void deleteProxy(AgentId from) throws java.lang.Exception
java.lang.Exception
- If the requester is not an administrator.public AgentId getId()
public void readBag(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public void writeBag(java.io.ObjectOutputStream out) throws java.io.IOException
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |