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

Class JmsMessageDispatcher

java.lang.Object

org.mule.jms.commons.internal.source.JmsMessageDispatcher

public class JmsMessageDispatcher
extends Object

Common utility which encapsulates the logic of dispatching a received message to a flow.

Since:

1.0.0

Constructor Summary

Constructors

Constructor	Description
JmsMessageDispatcher(JmsConfig<?,?> config, String defaultContentType, String defaultEncoding, JmsSpecification specification, Supplier<JmsSession> session, InternalAckMode ackMode, JmsSessionManager sessionManager, org.mule.runtime.extension.api.runtime.source.SourceCallback<Object,JmsAttributes> sourceCallback, JmsListenerLock jmsListenerLock, JmsConnectionExceptionResolver exceptionResolver)

Method Summary

Modifier and Type	Method	Description
void	dispatchMessage(jakarta.jms.Message message, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)	Dispatches the given message to the current source callback.

Methods inherited from class java.lang.Object

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

Constructor Details

JmsMessageDispatcher

public JmsMessageDispatcher(JmsConfig<?,?> config,
 String defaultContentType,
 String defaultEncoding,
 JmsSpecification specification,
 Supplier<JmsSession> session,
 InternalAckMode ackMode,
 JmsSessionManager sessionManager,
 org.mule.runtime.extension.api.runtime.source.SourceCallback<Object,JmsAttributes> sourceCallback,
 JmsListenerLock jmsListenerLock,
 JmsConnectionExceptionResolver exceptionResolver)

Method Details

dispatchMessage

public void dispatchMessage(jakarta.jms.Message message,
 org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)
                     throws Exception

Dispatches the given message to the current source callback.

Parameters:

message - Message to dispatch

context - Context to enrich with message and session information.

Throws:

Exception