com.caucho.amqp.common

Class AmqpSession

java.lang.Object

com.caucho.amqp.common.AmqpSession

public class AmqpSession
extends java.lang.Object

channel session management

Method Summary

Modifier and Type	Method and Description
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