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 |
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 |
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