com.caucho.amqp.client

Class AmqpClientSenderLink

java.lang.Object

com.caucho.amqp.common.AmqpLink

com.caucho.amqp.common.AmqpSenderLink

com.caucho.amqp.client.AmqpClientSenderLink

public class AmqpClientSenderLink
extends AmqpSenderLink

link session management

Constructor Summary

Constructors

Constructor and Description
AmqpClientSenderLink(java.lang.String name, java.lang.String address, com.caucho.amqp.client.AmqpClientSender<?> sender)

Method Summary

Modifier and Type	Method and Description
void	detach()
java.util.Map<java.lang.String,java.lang.Object>	getAttachProperties()
com.caucho.amqp.client.AmqpClientSender<?>	getSender()
java.util.Map<java.lang.String,java.lang.Object>	getSourceProperties()
java.util.Map<java.lang.String,java.lang.Object>	getTargetProperties()
long	nextMessageId()
void	onAccepted(long xid, long messageId)

Methods inherited from class com.caucho.amqp.common.AmqpSenderLink

getDeliveryCount, getLinkCredit, getRole, onFlow, transfer

Methods inherited from class com.caucho.amqp.common.AmqpLink

accepted, afterAttach, getAddress, getIncomingHandle, getName, getOutgoingHandle, getSession, modified, onModified, onRejected, onReleased, onTransfer, rejected, released, setIncomingHandle, setOutgoingHandle, setPeerDeliveryCount, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AmqpClientSenderLink

public AmqpClientSenderLink(java.lang.String name,
                            java.lang.String address,
                            com.caucho.amqp.client.AmqpClientSender<?> sender)

Method Detail

nextMessageId

public long nextMessageId()

getSender

public com.caucho.amqp.client.AmqpClientSender<?> getSender()

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

onAccepted

public void onAccepted(long xid,
                       long messageId)

Overrides:

onAccepted in class AmqpLink

Parameters:

messageId -

detach

public void detach()