Package com.swiftmq.impl.amqp

Class VersionedConnection

java.lang.Object

com.swiftmq.impl.amqp.VersionedConnection

All Implemented Interfaces:

OutboundHandler, InboundHandler, InboundHandler

public class VersionedConnection
extends java.lang.Object
implements InboundHandler, InboundHandler, OutboundHandler

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	TP_CONNECTIONSVC
static java.lang.String	TP_SESSIONSVC

Constructor Summary

Constructors

Constructor	Description
VersionedConnection(SwiftletContext ctx, Connection connection, Entity usage, boolean requiresSasl, Entity connectionTemplate)

Method Summary

Modifier and Type	Method	Description
void	close()
void	collect(long lastCollect)
void	dataAvailable(Connection connection, java.io.InputStream inputStream)	Will be called if data is available on the connection's input stream.
void	dataAvailable(LengthCaptureDataInput in)
ActiveLogin	getActiveLogin()
Connection	getConnection()
Entity	getConnectionTemplate()
java.lang.String	getRemoteHostname()
Entity	getUsage()
void	registerAMQPHandlerFactory(ProtocolHeader header, HandlerFactory factory)
void	registerSaslHandlerFactory(ProtocolHeader header, HandlerFactory factory)
void	send(Writable writable)	Send a Writable to the network.
void	setOutboundTracer(OutboundTracer outboundTracer)
void	setSaslFinished(boolean saslFinished, ActiveLogin activeLogin)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

TP_CONNECTIONSVC

public static final java.lang.String TP_CONNECTIONSVC

See Also:

Constant Field Values

TP_SESSIONSVC

public static final java.lang.String TP_SESSIONSVC

See Also:

Constant Field Values

Constructor Detail

VersionedConnection

public VersionedConnection(SwiftletContext ctx,
                           Connection connection,
                           Entity usage,
                           boolean requiresSasl,
                           Entity connectionTemplate)

Method Detail

getUsage

public Entity getUsage()

getConnectionTemplate

public Entity getConnectionTemplate()

getConnection

public Connection getConnection()

getActiveLogin

public ActiveLogin getActiveLogin()

getRemoteHostname

public java.lang.String getRemoteHostname()

setOutboundTracer

public void setOutboundTracer(OutboundTracer outboundTracer)

collect

public void collect(long lastCollect)

registerSaslHandlerFactory

public void registerSaslHandlerFactory(ProtocolHeader header,
                                       HandlerFactory factory)

registerAMQPHandlerFactory

public void registerAMQPHandlerFactory(ProtocolHeader header,
                                       HandlerFactory factory)

setSaslFinished

public void setSaslFinished(boolean saslFinished,
                            ActiveLogin activeLogin)

dataAvailable

public void dataAvailable(Connection connection,
                          java.io.InputStream inputStream)
                   throws java.io.IOException

Description copied from interface: InboundHandler

Will be called if data is available on the connection's input stream. The inbound handler must read this data out of the stream and should forward it to further processing to some async running task to return immediately. If this method throws an IOException, the connection will be closed.

Specified by:

dataAvailable in interface InboundHandler

Parameters:

connection - connection.

inputStream - the connections's input stream.

Throws:

java.io.IOException - on error to close the connection.

dataAvailable

public void dataAvailable(LengthCaptureDataInput in)

Specified by:

dataAvailable in interface InboundHandler

send

public void send(Writable writable)

Description copied from interface: OutboundHandler

Send a Writable to the network.

Specified by:

send in interface OutboundHandler

Parameters:

writable - Writable

close

public void close()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object