|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.amqp.common.AmqpLink
com.caucho.amqp.common.AmqpReceiverLink
com.caucho.amqp.server.AmqpServerReceiverLink
public class AmqpServerReceiverLink
link session management
Constructor Summary | |
---|---|
AmqpServerReceiverLink(java.lang.String name,
java.lang.String address,
BrokerSender sender)
|
Method Summary | |
---|---|
protected int |
getPrefetchAvailable()
|
protected void |
onTransfer(FrameTransfer transfer,
AmqpReader ain)
receives a message from the network |
Methods inherited from class com.caucho.amqp.common.AmqpReceiverLink |
---|
accepted, afterAttach, getRole, modified, rejected, released, setPeerDeliveryCount, setPrefetch, updatePrefetch, updateTake, updateTransfer |
Methods inherited from class com.caucho.amqp.common.AmqpLink |
---|
getAddress, getAttachProperties, getDeliveryCount, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, onAccepted, onFlow, onModified, onRejected, onReleased, setIncomingHandle, setOutgoingHandle, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public AmqpServerReceiverLink(java.lang.String name, java.lang.String address, BrokerSender sender)
Method Detail |
---|
protected void onTransfer(FrameTransfer transfer, AmqpReader ain) throws java.io.IOException
onTransfer
in class AmqpReceiverLink
java.io.IOException
protected int getPrefetchAvailable()
getPrefetchAvailable
in class AmqpReceiverLink
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |