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

Constructors

Constructor and Description
AmqpClientReceiverLink(java.lang.String name, java.lang.String address, com.caucho.amqp.client.AmqpClientReceiver<?> receiver)

Method Summary

Modifier and Type	Method and Description
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()