com.caucho.amqp.client
Class AmqpClientReceiverLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpReceiverLink
          extended by 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)
           
 
Method Summary
 void detach()
           
 java.util.Map<java.lang.String,java.lang.Object> getAttachProperties()
           
 com.caucho.amqp.client.AmqpClientReceiver<?> getReceiver()
           
 java.util.Map<java.lang.String,java.lang.Object> getSourceProperties()
           
 java.util.Map<java.lang.String,java.lang.Object> getTargetProperties()
           
protected  void onTransfer(FrameTransfer frameTransfer, AmqpReader ain)
          Receives the message from the network
 
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
 

Constructor Detail

AmqpClientReceiverLink

public AmqpClientReceiverLink(java.lang.String name,
                              java.lang.String address,
                              com.caucho.amqp.client.AmqpClientReceiver<?> receiver)
Method Detail

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()