Class ConnectionHandler

  • All Implemented Interfaces:
    org.apache.qpid.proton.engine.CoreHandler, org.apache.qpid.proton.engine.Handler
    Direct Known Subclasses:
    WebSocketConnectionHandler

    public class ConnectionHandler
    extends org.apache.qpid.proton.engine.BaseHandler
    • Constructor Detail

      • ConnectionHandler

        protected ConnectionHandler​(IAmqpConnection messagingFactory)
    • Method Detail

      • onConnectionInit

        public void onConnectionInit​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionInit in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionInit in class org.apache.qpid.proton.engine.BaseHandler
      • addTransportLayers

        public void addTransportLayers​(org.apache.qpid.proton.engine.Event event,
                                       org.apache.qpid.proton.engine.impl.TransportInternal transport)
      • notifyTransportErrors

        protected void notifyTransportErrors​(org.apache.qpid.proton.engine.Event event)
      • getOutboundSocketHostName

        public String getOutboundSocketHostName()
      • getOutboundSocketPort

        public int getOutboundSocketPort()
      • getProtocolPort

        public int getProtocolPort()
      • getMaxFrameSize

        public int getMaxFrameSize()
      • onConnectionBound

        public void onConnectionBound​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionBound in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionBound in class org.apache.qpid.proton.engine.BaseHandler
      • onTransportError

        public void onTransportError​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onTransportError in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onTransportError in class org.apache.qpid.proton.engine.BaseHandler
      • onConnectionRemoteOpen

        public void onConnectionRemoteOpen​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionRemoteOpen in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionRemoteOpen in class org.apache.qpid.proton.engine.BaseHandler
      • onConnectionRemoteClose

        public void onConnectionRemoteClose​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionRemoteClose in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionRemoteClose in class org.apache.qpid.proton.engine.BaseHandler
      • onConnectionFinal

        public void onConnectionFinal​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionFinal in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionFinal in class org.apache.qpid.proton.engine.BaseHandler
      • onConnectionLocalClose

        public void onConnectionLocalClose​(org.apache.qpid.proton.engine.Event event)
        Specified by:
        onConnectionLocalClose in interface org.apache.qpid.proton.engine.CoreHandler
        Overrides:
        onConnectionLocalClose in class org.apache.qpid.proton.engine.BaseHandler