com.caucho.amqp.common
Class AmqpLink
java.lang.Object
com.caucho.amqp.common.AmqpLink
- Direct Known Subclasses:
- AmqpReceiverLink, AmqpSenderLink
public abstract class AmqpLink
- extends java.lang.Object
link session management
Constructor Summary |
AmqpLink(java.lang.String name,
java.lang.String address)
|
Method Summary |
void |
accepted(long mid)
|
void |
afterAttach()
Called after the attach has been sent to the peer. |
java.lang.String |
getAddress()
|
java.util.Map<java.lang.String,java.lang.Object> |
getAttachProperties()
|
long |
getDeliveryCount()
|
int |
getIncomingHandle()
|
java.lang.String |
getName()
|
int |
getOutgoingHandle()
|
abstract FrameAttach.Role |
getRole()
|
AmqpSession |
getSession()
|
java.util.Map<java.lang.String,java.lang.Object> |
getSourceProperties()
|
java.util.Map<java.lang.String,java.lang.Object> |
getTargetProperties()
|
void |
modified(long mid,
boolean isFailure,
boolean isUndeliverableHere)
|
void |
onAccepted(long xid,
long messageId)
|
void |
onFlow(FrameFlow flow)
|
void |
onModified(long xid,
long mid,
boolean isFailed,
boolean isUndeliverableHere)
|
void |
onRejected(long xid,
long messageId,
AmqpError error)
|
void |
onReleased(long xid,
long messageId)
|
protected void |
onTransfer(FrameTransfer transfer,
AmqpReader ain)
Message receivers implement this method to receive a
message fragment from the network. |
void |
rejected(long mid,
java.lang.String errorMessage)
|
void |
released(long mid)
|
void |
setIncomingHandle(int handle)
|
void |
setOutgoingHandle(int handle)
|
void |
setPeerDeliveryCount(long deliveryCount)
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
AmqpLink
public AmqpLink(java.lang.String name,
java.lang.String address)
getName
public java.lang.String getName()
getAddress
public java.lang.String getAddress()
getRole
public abstract FrameAttach.Role getRole()
getAttachProperties
public java.util.Map<java.lang.String,java.lang.Object> getAttachProperties()
getSourceProperties
public java.util.Map<java.lang.String,java.lang.Object> getSourceProperties()
getTargetProperties
public java.util.Map<java.lang.String,java.lang.Object> getTargetProperties()
getSession
public AmqpSession getSession()
getIncomingHandle
public int getIncomingHandle()
setIncomingHandle
public void setIncomingHandle(int handle)
getOutgoingHandle
public int getOutgoingHandle()
setOutgoingHandle
public void setOutgoingHandle(int handle)
afterAttach
public void afterAttach()
- Called after the attach has been sent to the peer.
onTransfer
protected void onTransfer(FrameTransfer transfer,
AmqpReader ain)
throws java.io.IOException
- Message receivers implement this method to receive a
message fragment from the network.
- Throws:
java.io.IOException
onAccepted
public void onAccepted(long xid,
long messageId)
- Parameters:
messageId
-
onRejected
public void onRejected(long xid,
long messageId,
AmqpError error)
onReleased
public void onReleased(long xid,
long messageId)
- Parameters:
messageId
-
onModified
public void onModified(long xid,
long mid,
boolean isFailed,
boolean isUndeliverableHere)
accepted
public void accepted(long mid)
rejected
public void rejected(long mid,
java.lang.String errorMessage)
modified
public void modified(long mid,
boolean isFailure,
boolean isUndeliverableHere)
released
public void released(long mid)
getDeliveryCount
public long getDeliveryCount()
- Returns:
setPeerDeliveryCount
public void setPeerDeliveryCount(long deliveryCount)
onFlow
public void onFlow(FrameFlow flow)
- Parameters:
flow
-
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object