Interface EventHandler

All Known Implementing Classes:
AMQPConnectionContext
public interface EventHandler

  • Method Summary

    Modifier and Type
    Method
    Description
    default boolean
    flowControl(ReadyListener readyListener)
     
    default String
    getRemoteAddress()
     
    default void
    onAuthFailed(ProtonHandler protonHandler, org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onAuthInit(ProtonHandler handler, org.apache.qpid.proton.engine.Connection connection, boolean sasl)
     
    default void
    onAuthSuccess(ProtonHandler protonHandler, org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onDelivery(org.apache.qpid.proton.engine.Delivery delivery)
     
    default void
    onFinal(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onFinal(org.apache.qpid.proton.engine.Link link)
     
    default void
    onFinal(org.apache.qpid.proton.engine.Session session)
     
    default void
    onFlow(org.apache.qpid.proton.engine.Link link)
     
    default void
    onInit(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onInit(org.apache.qpid.proton.engine.Link link)
     
    default void
    onInit(org.apache.qpid.proton.engine.Session session)
     
    default void
    onLocalClose(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onLocalClose(org.apache.qpid.proton.engine.Link link)
     
    default void
    onLocalClose(org.apache.qpid.proton.engine.Session session)
     
    default void
    onLocalDetach(org.apache.qpid.proton.engine.Link link)
     
    default void
    onLocalOpen(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onLocalOpen(org.apache.qpid.proton.engine.Link link)
     
    default void
    onLocalOpen(org.apache.qpid.proton.engine.Session session)
     
    default void
    onRemoteClose(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onRemoteClose(org.apache.qpid.proton.engine.Link link)
     
    default void
    onRemoteClose(org.apache.qpid.proton.engine.Session session)
     
    default void
    onRemoteDetach(org.apache.qpid.proton.engine.Link link)
     
    default void
    onRemoteOpen(org.apache.qpid.proton.engine.Connection connection)
     
    default void
    onRemoteOpen(org.apache.qpid.proton.engine.Link link)
     
    default void
    onRemoteOpen(org.apache.qpid.proton.engine.Session session)
     
    default void
    onSaslMechanismsOffered(ProtonHandler handler, String[] mechanisms)
     
    default void
    onSaslRemoteMechanismChosen(ProtonHandler handler, String mech)
     
    default void
    onTransport(org.apache.qpid.proton.engine.Transport transport)
     
    default void
    onTransportError(org.apache.qpid.proton.engine.Transport transport)
     
    default void
    pushBytes(io.netty.buffer.ByteBuf bytes)
     

  • Method Details

    • onAuthInit

      default void onAuthInit(ProtonHandler handler, org.apache.qpid.proton.engine.Connection connection, boolean sasl)

    • onSaslRemoteMechanismChosen

      default void onSaslRemoteMechanismChosen(ProtonHandler handler, String mech)

    • onAuthFailed

      default void onAuthFailed(ProtonHandler protonHandler, org.apache.qpid.proton.engine.Connection connection)

    • onAuthSuccess

      default void onAuthSuccess(ProtonHandler protonHandler, org.apache.qpid.proton.engine.Connection connection)

    • onSaslMechanismsOffered

      default void onSaslMechanismsOffered(ProtonHandler handler, String[] mechanisms)

    • onInit

      default void onInit(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onLocalOpen

      default void onLocalOpen(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onRemoteOpen

      default void onRemoteOpen(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onLocalClose

      default void onLocalClose(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onRemoteClose

      default void onRemoteClose(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onFinal

      default void onFinal(org.apache.qpid.proton.engine.Connection connection) throws Exception
      Throws:
      Exception

    • onInit

      default void onInit(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onLocalOpen

      default void onLocalOpen(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onRemoteOpen

      default void onRemoteOpen(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onLocalClose

      default void onLocalClose(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onRemoteClose

      default void onRemoteClose(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onFinal

      default void onFinal(org.apache.qpid.proton.engine.Session session) throws Exception
      Throws:
      Exception

    • onInit

      default void onInit(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onLocalOpen

      default void onLocalOpen(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onRemoteOpen

      default void onRemoteOpen(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onLocalClose

      default void onLocalClose(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onRemoteClose

      default void onRemoteClose(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onFlow

      default void onFlow(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onFinal

      default void onFinal(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onRemoteDetach

      default void onRemoteDetach(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onLocalDetach

      default void onLocalDetach(org.apache.qpid.proton.engine.Link link) throws Exception
      Throws:
      Exception

    • onDelivery

      default void onDelivery(org.apache.qpid.proton.engine.Delivery delivery) throws Exception
      Throws:
      Exception

    • onTransportError

      default void onTransportError(org.apache.qpid.proton.engine.Transport transport) throws Exception
      Throws:
      Exception

    • onTransport

      default void onTransport(org.apache.qpid.proton.engine.Transport transport) throws Exception
      Throws:
      Exception

    • pushBytes

      default void pushBytes(io.netty.buffer.ByteBuf bytes)

    • flowControl

      default boolean flowControl(ReadyListener readyListener)

    • getRemoteAddress

      default String getRemoteAddress()