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

Constructors

Constructor and Description
AmqpLink(java.lang.String name, java.lang.String address)

Method Summary

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