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

Class JmsListener

java.lang.Object

org.mule.jms.commons.internal.source.JmsListener

public class JmsListener
extends Object

JMS Subscriber for Destinations, allows to listen for incoming Messages

Since:

1.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JmsListener.Builder

Constructor Summary

Constructors

Constructor	Description
JmsListener(JmsSessionManager sessionManager, JmsConfig<?,?> config, org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String inboundContentType, String inboundEncoding, int numberOfConsumers, SourceConfiguration sourceConfiguration, org.mule.runtime.api.scheduler.SchedulerService schedulerService)
JmsListener(JmsSessionManager sessionManager, JmsConfig<?,?> config, org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String inboundContentType, String inboundEncoding, int numberOfConsumers, SourceConfiguration sourceConfiguration, org.mule.runtime.api.scheduler.SchedulerService schedulerService, JmsConnectionExceptionResolver exceptionResolver, JmsResourceReleaser resourceCleaner)
JmsListener(JmsSessionManager sessionManager, JmsConfig<?,?> config, org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String inboundContentType, String inboundEncoding, int numberOfConsumers, SourceConfiguration sourceConfiguration, org.mule.runtime.api.scheduler.SchedulerService schedulerService, JmsConnectionExceptionResolver exceptionResolver, JmsResourceReleaser resourceCleaner, JmsListenerLockFactory lockFactory)
JmsListener(JmsSessionManager sessionManager, JmsConfig<?,?> config, org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String inboundContentType, String inboundEncoding, int numberOfConsumers, SourceConfiguration sourceConfiguration, org.mule.runtime.api.scheduler.SchedulerService schedulerService, JmsConnectionExceptionResolver exceptionResolver, JmsResourceReleaser resourceCleaner, JmsListenerLockFactory lockFactory, JmsReconnectionManager reconnectionManager)

Method Summary

Modifier and Type	Method	Description
void	disableConsumers()
static void	notifyIfConnectionProblem(org.mule.runtime.extension.api.runtime.source.SourceCallback<?,?> callback, Exception e, JmsConnectionExceptionResolver exceptionResolver)
void	onError(org.mule.runtime.api.message.Error error, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)
void	onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback sourceCallback)
void	onStop()
void	onSuccess(JmsResponseMessageBuilder<?> messageBuilder, org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)
void	restart()
void	startUsingCurrentSourceCallback()

Methods inherited from class java.lang.Object

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

Constructor Details

JmsListener

public JmsListener(JmsSessionManager sessionManager,
 JmsConfig<?,?> config,
 org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String inboundContentType,
 String inboundEncoding,
 int numberOfConsumers,
 SourceConfiguration sourceConfiguration,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService,
 JmsConnectionExceptionResolver exceptionResolver,
 JmsResourceReleaser resourceCleaner)

JmsListener

public JmsListener(JmsSessionManager sessionManager,
 JmsConfig<?,?> config,
 org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String inboundContentType,
 String inboundEncoding,
 int numberOfConsumers,
 SourceConfiguration sourceConfiguration,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService,
 JmsConnectionExceptionResolver exceptionResolver,
 JmsResourceReleaser resourceCleaner,
 JmsListenerLockFactory lockFactory)

JmsListener

public JmsListener(JmsSessionManager sessionManager,
 JmsConfig<?,?> config,
 org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String inboundContentType,
 String inboundEncoding,
 int numberOfConsumers,
 SourceConfiguration sourceConfiguration,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService)

JmsListener

public JmsListener(JmsSessionManager sessionManager,
 JmsConfig<?,?> config,
 org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection> connectionProvider,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String inboundContentType,
 String inboundEncoding,
 int numberOfConsumers,
 SourceConfiguration sourceConfiguration,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService,
 JmsConnectionExceptionResolver exceptionResolver,
 JmsResourceReleaser resourceCleaner,
 JmsListenerLockFactory lockFactory,
 JmsReconnectionManager reconnectionManager)

Method Details

notifyIfConnectionProblem

public static void notifyIfConnectionProblem(org.mule.runtime.extension.api.runtime.source.SourceCallback<?,?> callback,
 Exception e,
 JmsConnectionExceptionResolver exceptionResolver)

onStart

public void onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback sourceCallback)
             throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

onStop

public void onStop()

disableConsumers

public void disableConsumers()

restart

public void restart()
             throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

startUsingCurrentSourceCallback

public void startUsingCurrentSourceCallback()
                                     throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

onSuccess

public void onSuccess(JmsResponseMessageBuilder<?> messageBuilder,
 org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo,
 org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)

onError

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