Package org.wso2.carbon.inbound.endpoint.common

Class OneTimeTriggerAbstractCallback

java.lang.Object
org.wso2.carbon.inbound.endpoint.common.OneTimeTriggerAbstractCallback
Direct Known Subclasses:
MqttAsyncCallback
public abstract class OneTimeTriggerAbstractCallback extends Object
Generic callback implementation for one time trigger inbound endpoints. In this case Message injection is happens in a separate thread ( Callback ) per message.

  • Field Details

    • tenantDomain

      protected String tenantDomain

  • Constructor Details

    • OneTimeTriggerAbstractCallback

      public OneTimeTriggerAbstractCallback()

  • Method Details

    • handleReconnection

      protected void handleReconnection() throws InterruptedException
      Throws:
      InterruptedException

    • shutdown

      protected void shutdown()

    • reConnect

      protected abstract void reConnect()

    • releaseCallbackSuspension

      public void releaseCallbackSuspension()

    • isCallbackSuspended

      public boolean isCallbackSuspended()

    • setTenantDomain

      public void setTenantDomain(String tenantDomain)

    • startInboundTenantLoading

      public void startInboundTenantLoading(String inboundIdentifier)

    • setInboundRunnerMode

      public void setInboundRunnerMode(boolean isInboundRunnerMode)

    • isInboundRunnerMode

      public boolean isInboundRunnerMode()