Class ECPDSInterceptor

java.lang.Object
ecmwf.ecpds.mover.plugin.mqtt.ECPDSInterceptor
All Implemented Interfaces:
com.hivemq.extension.sdk.api.interceptor.Interceptor, com.hivemq.extension.sdk.api.interceptor.publish.PublishInboundInterceptor, com.hivemq.extension.sdk.api.interceptor.publish.PublishOutboundInterceptor
public class ECPDSInterceptor extends Object implements com.hivemq.extension.sdk.api.interceptor.publish.PublishInboundInterceptor, com.hivemq.extension.sdk.api.interceptor.publish.PublishOutboundInterceptor
The Class ECPDSInterceptor.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ECPDSInterceptor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onInboundPublish(@NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishInboundInput publishInboundInput, @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishInboundOutput publishInboundOutput)
    On inbound publish.
    void
    onOutboundPublish(@NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishOutboundInput publishOutboundInput, @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishOutboundOutput publishOutboundOutput)
    On outbound publish.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ECPDSInterceptor

      public ECPDSInterceptor()

  • Method Details

    • onInboundPublish

      public void onInboundPublish(@NotNull @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishInboundInput publishInboundInput, @NotNull @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishInboundOutput publishInboundOutput)
      On inbound publish.
      Specified by:
      onInboundPublish in interface com.hivemq.extension.sdk.api.interceptor.publish.PublishInboundInterceptor

    • onOutboundPublish

      public void onOutboundPublish(@NotNull @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishOutboundInput publishOutboundInput, @NotNull @NotNull com.hivemq.extension.sdk.api.interceptor.publish.parameter.PublishOutboundOutput publishOutboundOutput)
      On outbound publish.
      Specified by:
      onOutboundPublish in interface com.hivemq.extension.sdk.api.interceptor.publish.PublishOutboundInterceptor