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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 interfaceInboundHandler
- 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 interfaceInboundHandler
-
send
public void send(Writable writable)
Description copied from interface:OutboundHandler
Send a Writable to the network.- Specified by:
send
in interfaceOutboundHandler
- Parameters:
writable
- Writable
-
close
public void close()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-