Package com.swiftmq.impl.amqp

Class VersionedConnection

java.lang.Object
com.swiftmq.impl.amqp.VersionedConnection
public class VersionedConnection extends Object

  • Constructor Details

    • VersionedConnection

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

  • Method Details

    • getUsage

      public Entity getUsage()

    • getConnectionTemplate

      public Entity getConnectionTemplate()

    • getConnection

      public Connection getConnection()

    • getActiveLogin

      public ActiveLogin getActiveLogin()

    • getRemoteHostname

      public 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, InputStream inputStream) throws IOException
      Throws:
      IOException

    • dataAvailable

      public void dataAvailable(LengthCaptureDataInput in)

    • send

      public void send(Writable writable)

    • close

      public void close()

    • toString

      public String toString()
      Overrides:
      toString in class Object