Package org.mule.jms.commons.api.message

Class DefaultJmsMessageBuilder<D extends DefaultJmsDestination>

java.lang.Object

org.mule.jms.commons.api.message.DefaultJmsMessageBuilder<D>

All Implemented Interfaces:

JmsMessageBuilder<D>

Direct Known Subclasses:

DefaultJmsResponseMessageBuilder

public class DefaultJmsMessageBuilder<D extends DefaultJmsDestination>
extends Object
implements JmsMessageBuilder<D>

Enables the creation of an outgoing Message. Users must use this builder to create a message instance.

Since:

1.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BODY_CONTENT_TYPE_JMS_PROPERTY
static final String	BODY_ENCODING_JMS_PROPERTY

Constructor Summary

Constructors

Constructor	Description
DefaultJmsMessageBuilder()

Method Summary

Modifier and Type	Method	Description
jakarta.jms.Message	build(JmsSupport jmsSupport, org.mule.runtime.extension.api.runtime.parameter.OutboundCorrelationStrategy outboundCorrelationStrategy, org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo, jakarta.jms.Session session, JmsConfig<?,?> config)	Creates a Message based on the provided configurations
org.mule.runtime.api.metadata.TypedValue<Object>	getBody()
String	getCorrelationId()
String	getJmsType()
JmsxProperties	getJmsxProperties()
String	getOutboundContentType()
String	getOutboundEncoding()
Map<String,Object>	getProperties()
JmsDestination	getReplyTo()
boolean	isSendContentType()
boolean	isSendEncoding()
void	setBody(org.mule.runtime.api.metadata.TypedValue<Object> body)
void	setCorrelationId(String correlationId)
void	setJmsType(String jmsType)
void	setJmsxProperties(JmsxProperties jmsxProperties)
void	setOutboundContentType(String outboundContentType)
void	setOutboundEncoding(String outboundEncoding)
void	setProperties(Map<String,Object> properties)
void	setReplyTo(D replyTo)
void	setSendContentType(boolean sendContentType)
void	setSendEncoding(boolean sendEncoding)

Methods inherited from class java.lang.Object

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

Field Details

BODY_CONTENT_TYPE_JMS_PROPERTY

public static final String BODY_CONTENT_TYPE_JMS_PROPERTY

See Also:

• Constant Field Values

BODY_ENCODING_JMS_PROPERTY

public static final String BODY_ENCODING_JMS_PROPERTY

See Also:

• Constant Field Values

Constructor Details

DefaultJmsMessageBuilder

public DefaultJmsMessageBuilder()

Method Details

build

public jakarta.jms.Message build(JmsSupport jmsSupport,
 org.mule.runtime.extension.api.runtime.parameter.OutboundCorrelationStrategy outboundCorrelationStrategy,
 org.mule.runtime.extension.api.runtime.parameter.CorrelationInfo correlationInfo,
 jakarta.jms.Session session,
 JmsConfig<?,?> config)
                          throws jakarta.jms.JMSException,
IOException

Creates a Message based on the provided configurations

Specified by:

build in interface JmsMessageBuilder<D extends DefaultJmsDestination>

Parameters:

jmsSupport - the JmsSupport used to create the JMSReplyTo Destination

outboundCorrelationStrategy - the correlationId handling strategy

correlationInfo - the correlation information for the current message

session - the current Session

config - the current DefaultJmsProducerConfig

Returns:

the Message created by the user

Throws:

jakarta.jms.JMSException - if an error occurs

IOException

getBody

public org.mule.runtime.api.metadata.TypedValue<Object> getBody()

Specified by:

getBody in interface JmsMessageBuilder<D extends DefaultJmsDestination>

isSendContentType

public boolean isSendContentType()

Specified by:

isSendContentType in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getOutboundContentType

public String getOutboundContentType()

Specified by:

getOutboundContentType in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getProperties

public Map<String,Object> getProperties()

Specified by:

getProperties in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getJmsType

public String getJmsType()

Specified by:

getJmsType in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getCorrelationId

public String getCorrelationId()

Specified by:

getCorrelationId in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getJmsxProperties

public JmsxProperties getJmsxProperties()

Specified by:

getJmsxProperties in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getReplyTo

public JmsDestination getReplyTo()

Specified by:

getReplyTo in interface JmsMessageBuilder<D extends DefaultJmsDestination>

isSendEncoding

public boolean isSendEncoding()

Specified by:

isSendEncoding in interface JmsMessageBuilder<D extends DefaultJmsDestination>

getOutboundEncoding

public String getOutboundEncoding()

Specified by:

getOutboundEncoding in interface JmsMessageBuilder<D extends DefaultJmsDestination>

setJmsxProperties

public void setJmsxProperties(JmsxProperties jmsxProperties)

setProperties

public void setProperties(Map<String,Object> properties)

setReplyTo

public void setReplyTo(D replyTo)

setOutboundEncoding

public void setOutboundEncoding(String outboundEncoding)

setSendEncoding

public void setSendEncoding(boolean sendEncoding)

setOutboundContentType

public void setOutboundContentType(String outboundContentType)

setSendContentType

public void setSendContentType(boolean sendContentType)

setCorrelationId

public void setCorrelationId(String correlationId)

setJmsType

public void setJmsType(String jmsType)

setBody

public void setBody(org.mule.runtime.api.metadata.TypedValue<Object> body)