Class VersionedConnection

java.lang.Object

com.swiftmq.impl.amqp.VersionedConnection

All Implemented Interfaces:

com.swiftmq.amqp.OutboundHandler, com.swiftmq.net.client.InboundHandler, com.swiftmq.swiftlet.net.InboundHandler

public class VersionedConnection
extends Object
implements com.swiftmq.swiftlet.net.InboundHandler, com.swiftmq.net.client.InboundHandler, com.swiftmq.amqp.OutboundHandler

Constructor Summary

Constructors

Constructor	Description
VersionedConnection(SwiftletContext ctx, com.swiftmq.swiftlet.net.Connection connection, com.swiftmq.mgmt.Entity usage, boolean requiresSasl, com.swiftmq.mgmt.Entity connectionTemplate)

Method Summary

Modifier and Type	Method	Description
void	close()
void	collect(long lastCollect)
void	dataAvailable(com.swiftmq.swiftlet.net.Connection connection, InputStream inputStream)
void	dataAvailable(com.swiftmq.tools.util.LengthCaptureDataInput in)
com.swiftmq.swiftlet.auth.ActiveLogin	getActiveLogin()
com.swiftmq.swiftlet.net.Connection	getConnection()
com.swiftmq.mgmt.Entity	getConnectionTemplate()
String	getRemoteHostname()
com.swiftmq.mgmt.Entity	getUsage()
void	registerAMQPHandlerFactory(com.swiftmq.amqp.ProtocolHeader header, HandlerFactory factory)
void	registerSaslHandlerFactory(com.swiftmq.amqp.ProtocolHeader header, HandlerFactory factory)
void	send(com.swiftmq.amqp.Writable writable)
void	setOutboundTracer(OutboundTracer outboundTracer)
void	setSaslFinished(boolean saslFinished, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
String	toString()

Methods inherited from class Object

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

Constructor Details

VersionedConnection

public VersionedConnection(SwiftletContext ctx,
 com.swiftmq.swiftlet.net.Connection connection,
 com.swiftmq.mgmt.Entity usage,
 boolean requiresSasl,
 com.swiftmq.mgmt.Entity connectionTemplate)

Method Details

getUsage

public com.swiftmq.mgmt.Entity getUsage()

getConnectionTemplate

public com.swiftmq.mgmt.Entity getConnectionTemplate()

getConnection

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

getActiveLogin

public com.swiftmq.swiftlet.auth.ActiveLogin getActiveLogin()

getRemoteHostname

public String getRemoteHostname()

setOutboundTracer

public void setOutboundTracer(OutboundTracer outboundTracer)

collect

public void collect(long lastCollect)

registerSaslHandlerFactory

public void registerSaslHandlerFactory(com.swiftmq.amqp.ProtocolHeader header,
 HandlerFactory factory)

registerAMQPHandlerFactory

public void registerAMQPHandlerFactory(com.swiftmq.amqp.ProtocolHeader header,
 HandlerFactory factory)

setSaslFinished

public void setSaslFinished(boolean saslFinished,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

dataAvailable

public void dataAvailable(com.swiftmq.swiftlet.net.Connection connection,
 InputStream inputStream)
                   throws IOException

Specified by:

dataAvailable in interface com.swiftmq.swiftlet.net.InboundHandler

Throws:

IOException

dataAvailable

public void dataAvailable(com.swiftmq.tools.util.LengthCaptureDataInput in)

Specified by:

dataAvailable in interface com.swiftmq.net.client.InboundHandler

send

public void send(com.swiftmq.amqp.Writable writable)

Specified by:

send in interface com.swiftmq.amqp.OutboundHandler

close

public void close()

toString

public String toString()

Overrides:

toString in class Object