com.caucho.amqp.client
Class AmqpClientReceiverLink
java.lang.Object
com.caucho.amqp.common.AmqpLink
com.caucho.amqp.common.AmqpReceiverLink
com.caucho.amqp.client.AmqpClientReceiverLink
public class AmqpClientReceiverLink
- extends AmqpReceiverLink
link session management
Constructor Summary |
AmqpClientReceiverLink(java.lang.String name,
java.lang.String address,
com.caucho.amqp.client.AmqpClientReceiver<?> receiver)
|
Methods inherited from class com.caucho.amqp.common.AmqpReceiverLink |
accepted, afterAttach, getPrefetchAvailable, getRole, modified, rejected, released, setPeerDeliveryCount, setPrefetch, updatePrefetch, updateTake, updateTransfer |
Methods inherited from class com.caucho.amqp.common.AmqpLink |
getAddress, getDeliveryCount, getIncomingHandle, getName, getOutgoingHandle, getSession, 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 |
AmqpClientReceiverLink
public AmqpClientReceiverLink(java.lang.String name,
java.lang.String address,
com.caucho.amqp.client.AmqpClientReceiver<?> receiver)
getReceiver
public com.caucho.amqp.client.AmqpClientReceiver<?> getReceiver()
getAttachProperties
public java.util.Map<java.lang.String,java.lang.Object> getAttachProperties()
- Overrides:
getAttachProperties
in class AmqpLink
getSourceProperties
public java.util.Map<java.lang.String,java.lang.Object> getSourceProperties()
- Overrides:
getSourceProperties
in class AmqpLink
getTargetProperties
public java.util.Map<java.lang.String,java.lang.Object> getTargetProperties()
- Overrides:
getTargetProperties
in class AmqpLink
onTransfer
protected void onTransfer(FrameTransfer frameTransfer,
AmqpReader ain)
throws java.io.IOException
- Receives the message from the network
- Overrides:
onTransfer
in class AmqpReceiverLink
- Throws:
java.io.IOException
detach
public void detach()