Class ServerLink
java.lang.Object
com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
- Direct Known Subclasses:
SourceLink,TargetLink
-
Constructor Summary
ConstructorsConstructorDescriptionServerLink(SwiftletContext ctx, SessionHandler mySessionHandler, String name) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()abstract voidprotected intAddressIFDestinationgetName()AddressIFprotected longPOObjectbooleanisClosed()booleanvoidsetDesiredCapabilities(Set desiredCapabilities) voidsetDynamic(boolean dynamic) protected voidsetHandle(int handle) voidsetLocalAddress(AddressIF localAddress) voidsetOfferedCapabilities(Set offeredCapabilities) protected voidsetRemoteAddress(AddressIF remoteAddress) protected voidsetRemoteHandle(long remoteHandle) abstract voidsettle(long deliveryId, DeliveryStateIF deliveryState) abstract voidsetUsage(Entity usage) voidsetWaitingPO(POObject waitingPO) void
-
Constructor Details
-
ServerLink
-
-
Method Details
-
getName
-
setHandle
protected void setHandle(int handle) -
getHandle
protected int getHandle() -
setRemoteHandle
protected void setRemoteHandle(long remoteHandle) -
getRemoteAddress
public AddressIF getRemoteAddress() -
setRemoteAddress
protected void setRemoteAddress(AddressIF remoteAddress) -
getRemoteHandle
protected long getRemoteHandle() -
getOfferedCapabilities
-
setOfferedCapabilities
-
getDesiredCapabilities
-
setDesiredCapabilities
-
isClosed
public boolean isClosed() -
setLocalAddress
public void setLocalAddress(AddressIF localAddress) -
getLocalAddress
public AddressIF getLocalAddress() -
getLocalDestination
public Destination getLocalDestination() -
isDynamic
public boolean isDynamic() -
setDynamic
public void setDynamic(boolean dynamic) -
getMySessionHandler
-
getWaitingPO
public POObject getWaitingPO() -
setWaitingPO
public void setWaitingPO(POObject waitingPO) -
verifyLocalAddress
public void verifyLocalAddress() throws AuthenticationException, QueueException, TopicException, InvalidSelectorException- Throws:
AuthenticationExceptionQueueExceptionTopicExceptionInvalidSelectorException
-
settle
public abstract void settle(long deliveryId, DeliveryStateIF deliveryState) throws EndWithErrorException - Throws:
EndWithErrorException
-
setUsage
public abstract void setUsage(Entity usage) -
fillUsage
public abstract void fillUsage() -
close
public void close()
-