Package org.mule.jms.commons.internal.operation

Class JmsPublishConsume

java.lang.Object

org.mule.jms.commons.internal.operation.JmsPublishConsume

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable

public class JmsPublishConsume
extends Object
implements org.mule.runtime.api.lifecycle.Disposable

Operation that allows the user to send a message to a JMS Destination and waits for a response either to the provided ReplyTo destination or to a temporary Destination created dynamically

Since:

1.0

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor	Description
JmsPublishConsume(JmsSessionManager sessionManager, org.mule.runtime.api.scheduler.SchedulerService schedulerService)

Method Summary

Modifier and Type	Method	Description
void	dispose()
void	publishConsume(JmsConfig<?,?> config, JmsConnection connection, String destination, JmsMessageBuilder<?> messageBuilder, JmsPublishParameters publishParameters, JmsConsumeParameters consumeParameters, org.mule.runtime.extension.api.runtime.parameter.OutboundCorrelationStrategy sendCorrelationId, org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo, RequestReplyPattern requestReplyPattern, org.mule.runtime.extension.api.runtime.process.CompletionCallback<Object,JmsAttributes> completionCallback)	Operation that allows the user to send a message to a JMS Destination and waits for a response either to the provided ReplyTo destination or to a temporary Destination created dynamically

Methods inherited from class java.lang.Object

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

Constructor Details

JmsPublishConsume

public JmsPublishConsume(JmsSessionManager sessionManager,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService)

Method Details

publishConsume

@OutputResolver(output=JmsOutputResolver.class)
@Throws(JmsPublishConsumeErrorTypeProvider.class)
public void publishConsume(@Config
 JmsConfig<?,?> config,
 @Connection
 JmsConnection connection,
 @Placement(order=0) @Summary("The name of the Queue destination where the Message should be sent")
 String destination,
 @Placement(order=1) @Summary("A builder for the message that will be published") @ParameterGroup(name="Message",showInDsl=true)
 JmsMessageBuilder<?> messageBuilder,
 @Placement(order=2) @ParameterGroup(name="Publish Configuration",showInDsl=true)
 JmsPublishParameters publishParameters,
 @Placement(order=3) @ParameterGroup(name="Consume Configuration",showInDsl=true)
 JmsConsumeParameters consumeParameters,
 @ConfigOverride
 org.mule.runtime.extension.api.runtime.parameter.OutboundCorrelationStrategy sendCorrelationId,
 org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo,
 RequestReplyPattern requestReplyPattern,
 org.mule.runtime.extension.api.runtime.process.CompletionCallback<Object,JmsAttributes> completionCallback)
                    throws JmsExtensionException

Operation that allows the user to send a message to a JMS Destination and waits for a response either to the provided ReplyTo destination or to a temporary Destination created dynamically

Parameters:

config - the current DefaultJmsProducerConfig

connection - the current JmsConnection

destination - the name of the Destination where the Message should be sent

messageBuilder - the DefaultJmsMessageBuilder used to create the Message to be sent

publishParameters - Parameter group that lets override the publish configuration

consumeParameters - Parameter group that lets override the consume configuration

sendCorrelationId - options on whether to include an outbound correlation id or not

correlationInfo - the current message's correlation info

Throws:

JmsExtensionException - if an error occurs

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.api.lifecycle.Disposable