Class RabbitMQListener
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
-
- org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQListener
-
- All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor
public class RabbitMQListener extends InboundOneTimeTriggerRequestProcessor
The listener implementation to initialize the RabbitMQ consumer once with inbound parameters.
-
-
Field Summary
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
COMMON_ENDPOINT_POSTFIX, coordination, name, startUpController, synapseEnvironment, TASK_THRESHOLD_INTERVAL
-
-
Constructor Summary
Constructors Constructor Description RabbitMQListener(org.apache.synapse.inbound.InboundProcessorParams params)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stopvoid
init()
-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
start
-
-
-
-
Method Detail
-
destroy
public void destroy()
Description copied from class:InboundOneTimeTriggerRequestProcessor
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop- Specified by:
destroy
in interfaceorg.apache.synapse.inbound.InboundRequestProcessor
- Overrides:
destroy
in classInboundOneTimeTriggerRequestProcessor
-
init
public void init()
-
-