protected class MultiConsumerJmsMessageReceiver.SubReceiver extends Object implements MessageListener
Modifier and Type | Field and Description |
---|---|
protected boolean |
connected |
protected boolean |
isProcessingMessage |
protected boolean |
started |
Modifier | Constructor and Description |
---|---|
protected |
MultiConsumerJmsMessageReceiver.SubReceiver() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConsumer() |
protected void |
createConsumer()
Create a consumer for the jms destination.
|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doStart() |
protected void |
doStop(boolean force)
Stop the subreceiver.
|
void |
onMessage(Message message) |
protected volatile boolean connected
protected volatile boolean started
protected volatile boolean isProcessingMessage
protected MultiConsumerJmsMessageReceiver.SubReceiver()
protected void doConnect() throws MuleException
MuleException
protected void doDisconnect() throws MuleException
MuleException
protected void closeConsumer()
protected void doStart() throws MuleException
MuleException
protected void doStop(boolean force) throws MuleException
force
- - if true, any exceptions will be logged but the subreceiver will be considered stopped regardlessMuleException
- only if force = falseprotected void createConsumer() throws Exception
Exception
public void onMessage(Message message)
onMessage
in interface MessageListener
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.