Interface PingReqInboundInterceptor

  • All Superinterfaces:
    Interceptor
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

    @FunctionalInterface
    public interface PingReqInboundInterceptor
    extends Interceptor
    Interface for the ping request inbound interception.

    Interceptors are always called by the same Thread for all messages from the same client.

    If the same instance is shared between multiple clients it can be called in different Threads and must therefore be thread-safe.

    Since:
    4.3.0, CE 2020.1
    • Method Detail

      • onInboundPingReq

        void onInboundPingReq​(@NotNull PingReqInboundInput pingReqInboundInput,
                              @NotNull PingReqInboundOutput pingReqInboundOutput)
        When a PingReqInboundInterceptor is set through any extension, this method gets called for every inbound PINGREQ packet from any MQTT client.

        The execution of interceptor delays the handling of the PINGREQ. Therefore the client may get disconnected if the execution of the interceptor takes to long.

        Parameters:
        pingReqInboundInput - The PingReqInboundInput parameter.
        pingReqInboundOutput - The PingReqInboundOutput parameter.
        Since:
        4.3.0, CE 2020.1