com.caucho.amqp.common
Class AmqpLink

java.lang.Object
  extended by 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
 

Constructor Detail

AmqpLink

public AmqpLink(java.lang.String name,
                java.lang.String address)
Method Detail

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