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 Summary
Fields Modifier and Type Field Description protected String
tenantDomain
-
Constructor Summary
Constructors Constructor Description OneTimeTriggerAbstractCallback()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
handleReconnection()
boolean
isCallbackSuspended()
boolean
isInboundRunnerMode()
protected abstract void
reConnect()
void
releaseCallbackSuspension()
void
setInboundRunnerMode(boolean isInboundRunnerMode)
void
setTenantDomain(String tenantDomain)
protected void
shutdown()
void
startInboundTenantLoading(String inboundIdentifier)
-
-
-
Field Detail
-
tenantDomain
protected String tenantDomain
-
-
Method Detail
-
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()
-
-