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 |
AmqpClientSenderLink(java.lang.String name,
java.lang.String address,
com.caucho.amqp.client.AmqpClientSender<?> sender)
|
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 |
AmqpClientSenderLink
public AmqpClientSenderLink(java.lang.String name,
java.lang.String address,
com.caucho.amqp.client.AmqpClientSender<?> sender)
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()