Class RoutingConnection

java.lang.Object

com.swiftmq.impl.routing.single.connection.RoutingConnection

All Implemented Interfaces:

com.swiftmq.tools.requestreply.RequestService

public class RoutingConnection
extends Object
implements com.swiftmq.tools.requestreply.RequestService

Constructor Summary

Constructors

Constructor	Description
RoutingConnection(SwiftletContext ctx, com.swiftmq.swiftlet.net.Connection connection, com.swiftmq.mgmt.Entity entity, String password)

Method Summary

Modifier and Type	Method	Description
void	close()
void	enqueueRequest(com.swiftmq.tools.requestreply.Request request)
ActivationListener	getActivationListener()
com.swiftmq.swiftlet.net.Connection	getConnection()
String	getConnectionId()
com.swiftmq.mgmt.Entity	getEntity()
long	getKeepaliveInterval()
com.swiftmq.swiftlet.threadpool.EventLoop	getOutboundQueue()
String	getPassword()
String	getProtocolVersion()
String	getRemoteHostName()
String	getRouterName()
SMQRFactory	getSMQRFactory()
int	getTransactionSize()
SMQRVisitor	getVisitor()
int	getWindowSize()
boolean	isClosed()
boolean	isListener()
boolean	isXa()
void	serviceRequest(com.swiftmq.tools.requestreply.Request request)
void	setActivationListener(ActivationListener activationListener)
void	setKeepaliveInterval(long keepaliveInterval)
void	setProtocolVersion(String protocolVersion)
void	setRouterName(String routerName)
void	setTransactionSize(int transactionSize)
void	setUsageEntity(com.swiftmq.mgmt.Entity usageEntity)
void	setWindowSize(int windowSize)
void	setXaSelected(boolean xaSelected)
String	toString()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RoutingConnection

public RoutingConnection(SwiftletContext ctx,
 com.swiftmq.swiftlet.net.Connection connection,
 com.swiftmq.mgmt.Entity entity,
 String password)
                  throws IOException

Throws:

IOException

Method Details

setUsageEntity

public void setUsageEntity(com.swiftmq.mgmt.Entity usageEntity)

getProtocolVersion

public String getProtocolVersion()

setProtocolVersion

public void setProtocolVersion(String protocolVersion)

setXaSelected

public void setXaSelected(boolean xaSelected)

getActivationListener

public ActivationListener getActivationListener()

setActivationListener

public void setActivationListener(ActivationListener activationListener)

getEntity

public com.swiftmq.mgmt.Entity getEntity()

getTransactionSize

public int getTransactionSize()

setTransactionSize

public void setTransactionSize(int transactionSize)

getWindowSize

public int getWindowSize()

setWindowSize

public void setWindowSize(int windowSize)

getSMQRFactory

public SMQRFactory getSMQRFactory()

getPassword

public String getPassword()

isListener

public boolean isListener()

setKeepaliveInterval

public void setKeepaliveInterval(long keepaliveInterval)

getKeepaliveInterval

public long getKeepaliveInterval()

isXa

public boolean isXa()

getConnection

public com.swiftmq.swiftlet.net.Connection getConnection()

getVisitor

public SMQRVisitor getVisitor()

getOutboundQueue

public com.swiftmq.swiftlet.threadpool.EventLoop getOutboundQueue()

setRouterName

public void setRouterName(String routerName)

getRouterName

public String getRouterName()

getRemoteHostName

public String getRemoteHostName()

getConnectionId

public String getConnectionId()

serviceRequest

public void serviceRequest(com.swiftmq.tools.requestreply.Request request)

Specified by:

serviceRequest in interface com.swiftmq.tools.requestreply.RequestService

enqueueRequest

public void enqueueRequest(com.swiftmq.tools.requestreply.Request request)
                    throws Exception

Throws:

Exception

isClosed

public boolean isClosed()

close

public void close()

toString

public String toString()

Overrides:

toString in class Object