Class InboundNatsListener

java.lang.Object
org.wso2.carbon.inbound.endpoint.protocol.nats.InboundNatsListener
All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor

public class InboundNatsListener extends Object implements org.apache.synapse.inbound.InboundRequestProcessor
Listener class for NATS Inbound Endpoint which is triggered by inbound core
  • Constructor Details

    • InboundNatsListener

      public InboundNatsListener(org.apache.synapse.inbound.InboundProcessorParams params)
  • Method Details

    • init

      public void init()
      Specified by:
      init in interface org.apache.synapse.inbound.InboundRequestProcessor
    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.apache.synapse.inbound.InboundRequestProcessor
    • pause

      public void pause()
      Specified by:
      pause in interface org.apache.synapse.inbound.InboundRequestProcessor
    • activate

      public boolean activate()
      Specified by:
      activate in interface org.apache.synapse.inbound.InboundRequestProcessor
    • deactivate

      public boolean deactivate()
      Specified by:
      deactivate in interface org.apache.synapse.inbound.InboundRequestProcessor
    • isDeactivated

      public boolean isDeactivated()
      Specified by:
      isDeactivated in interface org.apache.synapse.inbound.InboundRequestProcessor