|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.server.cluster.SimpleMemberHandle
org.apache.qpid.server.cluster.MinaBrokerProxy
public class MinaBrokerProxy
A 'client stub' for a remote cluster peer, using MINA for IO Layer
Method Summary | |
---|---|
void |
addFailureListener(org.apache.qpid.server.cluster.MemberFailureListener listener)
Allows a listener to be registered that will receive callbacks when communication to the peer this broker instance represents fails. |
protected void |
failed()
Allows subclasses to signal comunication failures |
void |
handle(int channel,
org.apache.qpid.framing.AMQMethodBody method)
|
protected boolean |
handleResponse(int channel,
org.apache.qpid.framing.AMQMethodBody response)
Subclasses should call this on receiving message responses from the remote peer. |
void |
send(org.apache.qpid.framing.AMQDataBlock data)
|
java.lang.String |
toString()
|
Methods inherited from class org.apache.qpid.server.cluster.SimpleMemberHandle |
---|
equals, getDetails, getHost, getPort, hashCode, matches, matches, resolve, resolve |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.qpid.server.cluster.MemberHandle |
---|
getDetails, getHost, getPort, matches, matches |
Method Detail |
---|
public void send(org.apache.qpid.framing.AMQDataBlock data) throws org.apache.qpid.AMQException
send
in interface Member
org.apache.qpid.AMQException
public void handle(int channel, org.apache.qpid.framing.AMQMethodBody method) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public java.lang.String toString()
toString
in class SimpleMemberHandle
public void addFailureListener(org.apache.qpid.server.cluster.MemberFailureListener listener)
addFailureListener
in interface Member
listener
- the callback to be notified of failuresprotected void failed()
protected boolean handleResponse(int channel, org.apache.qpid.framing.AMQMethodBody response)
channel
- the channel on which the method was receivedresponse
- the response received
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |