com.caucho.amqp.client
Class AmqpClientSenderLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpSenderLink
          extended by 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)
           
 
Method Summary
 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()