com.caucho.amqp.server
Class AmqpServerSenderLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpSenderLink
          extended by com.caucho.amqp.server.AmqpServerSenderLink

public class AmqpServerSenderLink
extends AmqpSenderLink

link session management


Constructor Summary
AmqpServerSenderLink(java.lang.String name, java.lang.String address, SettleMode settleMode)
           
 
Method Summary
 void onAccepted(long xid, long mid)
           
 void onFlow(FrameFlow flow)
          When peer sends its link credit, update deliveryLimit.
 void onModified(long xid, long mid, boolean isFailed, boolean isUndeliverableHere)
           
 void onRejected(long xid, long messageId, AmqpError error)
           
 void onReleased(long xid, long messageId)
           
 
Methods inherited from class com.caucho.amqp.common.AmqpSenderLink
getDeliveryCount, getLinkCredit, getRole, transfer
 
Methods inherited from class com.caucho.amqp.common.AmqpLink
accepted, afterAttach, getAddress, getAttachProperties, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, modified, 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

AmqpServerSenderLink

public AmqpServerSenderLink(java.lang.String name,
                            java.lang.String address,
                            SettleMode settleMode)
Method Detail

onAccepted

public void onAccepted(long xid,
                       long mid)
Overrides:
onAccepted in class AmqpLink

onReleased

public void onReleased(long xid,
                       long messageId)
Overrides:
onReleased in class AmqpLink

onRejected

public void onRejected(long xid,
                       long messageId,
                       AmqpError error)
Overrides:
onRejected in class AmqpLink

onModified

public void onModified(long xid,
                       long mid,
                       boolean isFailed,
                       boolean isUndeliverableHere)
Overrides:
onModified in class AmqpLink

onFlow

public void onFlow(FrameFlow flow)
Description copied from class: AmqpSenderLink
When peer sends its link credit, update deliveryLimit.

Overrides:
onFlow in class AmqpSenderLink
Parameters:
flow -