Package org.mule.jms.commons.internal.source.push

Class JmsMessageListenerDelegate

java.lang.Object

org.mule.jms.commons.internal.source.push.JmsMessageListenerDelegate

All Implemented Interfaces:

MessageConsumerDelegate

public class JmsMessageListenerDelegate
extends Object
implements MessageConsumerDelegate

MessageConsumerDelegate implementation which uses MessageListener

Since:

1.0

Constructor Summary

Constructors

Constructor	Description
JmsMessageListenerDelegate(JmsMessageListenerFactory<?> messageListenerFactory, JmsConnection connection, JmsSupport jmsSupport, ConsumerType consumerType, String destination, JmsConfig<?,?> config, InternalAckMode resolvedAckMode, String selector, JmsListenerLockFactory lockFactory, JmsResourceReleaser resourceCleaner)

Method Summary

Modifier and Type	Method	Description
protected void	closeConsumerQuietly(MessageListenerContext info)
void	createConsumers(int numberOfConsumers)	Creates and start N consumers, where N is defined by the param numberOfConsumers.
protected void	disableConsumerListener(MessageListenerContext info)
void	disableConsumers()
void	onError(org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext, org.mule.runtime.api.message.Error error)	Communicates when a message has not been successfully processed in a flow.
void	onSuccess(org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)	Communicates when a message has been successfully processed in a flow.
void	stop()	Request to stop all the message consumers.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JmsMessageListenerDelegate

public JmsMessageListenerDelegate(JmsMessageListenerFactory<?> messageListenerFactory,
 JmsConnection connection,
 JmsSupport jmsSupport,
 ConsumerType consumerType,
 String destination,
 JmsConfig<?,?> config,
 InternalAckMode resolvedAckMode,
 String selector,
 JmsListenerLockFactory lockFactory,
 JmsResourceReleaser resourceCleaner)

Method Details

createConsumers

public void createConsumers(int numberOfConsumers)
                     throws org.mule.runtime.api.connection.ConnectionException

Creates and start N consumers, where N is defined by the param numberOfConsumers.

Specified by:

createConsumers in interface MessageConsumerDelegate

Parameters:

numberOfConsumers - number of consumers to create and start.

Throws:

org.mule.runtime.api.connection.ConnectionException - If an error occurs trying to create and start the consumers.

onSuccess

public void onSuccess(org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)

Communicates when a message has been successfully processed in a flow.

Specified by:

onSuccess in interface MessageConsumerDelegate

Parameters:

callbackContext - Context with references of the processed message.

stop

public void stop()

Request to stop all the message consumers.

Specified by:

stop in interface MessageConsumerDelegate

disableConsumers

public void disableConsumers()

Specified by:

disableConsumers in interface MessageConsumerDelegate

disableConsumerListener

protected void disableConsumerListener(MessageListenerContext info)

closeConsumerQuietly

protected void closeConsumerQuietly(MessageListenerContext info)

onError

public void onError(org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext,
 org.mule.runtime.api.message.Error error)

Communicates when a message has not been successfully processed in a flow.

Specified by:

onError in interface MessageConsumerDelegate

Parameters:

callbackContext - Context with references of the processed message.

error - Produced error on the flow.