com.caucho.amqp.common
Class AmqpSession

java.lang.Object
  extended by com.caucho.amqp.common.AmqpSession

public class AmqpSession
extends java.lang.Object

channel session management


Method Summary
 void accepted(long deliveryId)
           
 boolean addReceiverLink(AmqpReceiverLink link, DistributionMode distMode, SettleMode settleMode)
           
 boolean addSenderLink(AmqpSenderLink link, SettleMode settleMode)
           
 AmqpLink detachOutgoingLink(int handle)
           
 int getOutgoingIndex()
           
 AmqpLink getOutgoingLink(int handle)
           
 void modified(long deliveryId, boolean isFailed, boolean isUndeliverableHere)
           
 void onAccepted(long deliveryId)
           
 void onFlow(FrameFlow flow)
           
 void onReceiverDisposition(long xid, DeliveryState state, long first, long last)
           
 void onRejected(long deliveryId, java.lang.String msg)
           
 void onSenderDisposition(long xid, DeliveryState state, long first, long last)
           
 void outgoingAccepted(long deliveryId)
           
 void rejected(long deliveryId, java.lang.String errorMessage)
           
 void released(long deliveryId)
           
 java.lang.String toString()
           
 void transfer(AmqpSenderLink link, long mid, SettleMode settleMode, java.io.InputStream is)
          Sends a message to the network.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

getOutgoingIndex

public int getOutgoingIndex()

addSenderLink

public boolean addSenderLink(AmqpSenderLink link,
                             SettleMode settleMode)

addReceiverLink

public boolean addReceiverLink(AmqpReceiverLink link,
                               DistributionMode distMode,
                               SettleMode settleMode)

detachOutgoingLink

public AmqpLink detachOutgoingLink(int handle)

getOutgoingLink

public AmqpLink getOutgoingLink(int handle)

transfer

public void transfer(AmqpSenderLink link,
                     long mid,
                     SettleMode settleMode,
                     java.io.InputStream is)
Sends a message to the network.


accepted

public void accepted(long deliveryId)

outgoingAccepted

public void outgoingAccepted(long deliveryId)

rejected

public void rejected(long deliveryId,
                     java.lang.String errorMessage)
Parameters:
handle -

modified

public void modified(long deliveryId,
                     boolean isFailed,
                     boolean isUndeliverableHere)
Parameters:
handle -

released

public void released(long deliveryId)
Parameters:
handle -

onFlow

public void onFlow(FrameFlow flow)

onSenderDisposition

public void onSenderDisposition(long xid,
                                DeliveryState state,
                                long first,
                                long last)

onReceiverDisposition

public void onReceiverDisposition(long xid,
                                  DeliveryState state,
                                  long first,
                                  long last)

onAccepted

public void onAccepted(long deliveryId)
Parameters:
deliveryId -

onRejected

public void onRejected(long deliveryId,
                       java.lang.String msg)
Parameters:
deliveryId -
msg -

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object