org.apache.activemq.artemis.jms.client

Class ActiveMQJMSProducer

java.lang.Object

org.apache.activemq.artemis.jms.client.ActiveMQJMSProducer

All Implemented Interfaces:

JMSProducer

public final class ActiveMQJMSProducer
extends Object
implements JMSProducer

NOTE: this class forwards setDisableMessageID(boolean) and setDisableMessageTimestamp(boolean) calls their equivalent at the MessageProducer. IF the user is using the producer in async mode, this may lead to races. We allow/tolerate this because these are just optional optimizations.

Method Summary

Modifier and Type	Method and Description
JMSProducer	clearProperties() Clears any message properties set on this JMSProducer
CompletionListener	getAsync() If subsequent calls to send on this JMSProducer object have been configured to be asynchronous then this method returns the CompletionListener that has previously been configured.
boolean	getBooleanProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a boolean.
byte	getByteProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a String.
long	getDeliveryDelay() Gets the minimum length of time in milliseconds that must elapse after a message is sent before the Jakarta Messaging provider may deliver the message to a consumer.
int	getDeliveryMode() Returns the delivery mode of messages that are sent using this JMSProducer
boolean	getDisableMessageID() Gets an indication of whether message IDs are disabled.
boolean	getDisableMessageTimestamp() Gets an indication of whether message timestamps are disabled.
double	getDoubleProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a double.
float	getFloatProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a float.
int	getIntProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a int.
String	getJMSCorrelationID() Returns the JMSCorrelationID header value that has been set on this JMSProducer, as a String.
byte[]	getJMSCorrelationIDAsBytes() Returns the JMSCorrelationID header value that has been set on this JMSProducer, as an array of bytes.
Destination	getJMSReplyTo() Returns the JMSReplyTo header value that has been set on this JMSProducer.
String	getJMSType() Returns the JMSType header value that has been set on this JMSProducer.
long	getLongProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a long.
Object	getObjectProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to objectified format.
int	getPriority() Return the priority of messages that are sent using this JMSProducer
Set<String>	getPropertyNames() Returns an unmodifiable Set view of the names of all the message properties that have been set on this JMSProducer.
short	getShortProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a short.
String	getStringProperty(String name) Returns the message property with the specified name that has been set on this JMSProducer, converted to a String.
long	getTimeToLive() Returns the time to live of messages that are sent using this JMSProducer.
boolean	propertyExists(String name) Indicates whether a message property with the specified name has been set on this JMSProducer
JMSProducer	send(Destination destination, byte[] body) Send a BytesMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.
JMSProducer	send(Destination destination, Map<String,Object> body) Send a MapMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.
JMSProducer	send(Destination destination, Message message) Sends a message to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.
JMSProducer	send(Destination destination, Serializable body) Send an ObjectMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.
JMSProducer	send(Destination destination, String body) Send a TextMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.
JMSProducer	setAsync(CompletionListener completionListener) Specifies whether subsequent calls to send on this JMSProducer object should be synchronous or asynchronous.
JMSProducer	setDeliveryDelay(long deliveryDelay) Sets the minimum length of time in milliseconds that must elapse after a message is sent before the Jakarta Messaging provider may deliver the message to a consumer.
JMSProducer	setDeliveryMode(int deliveryMode) Specifies the delivery mode of messages that are sent using this JMSProducer
JMSProducer	setDisableMessageID(boolean value) Specifies whether message IDs may be disabled for messages that are sent using this JMSProducer
JMSProducer	setDisableMessageTimestamp(boolean value) Specifies whether message timestamps may be disabled for messages that are sent using this JMSProducer.
JMSProducer	setJMSCorrelationID(String correlationID) Specifies that messages sent using this JMSProducer will have their JMSCorrelationID header value set to the specified correlation ID, where correlation ID is specified as a String.
JMSProducer	setJMSCorrelationIDAsBytes(byte[] correlationID) Specifies that messages sent using this JMSProducer will have their JMSCorrelationID header value set to the specified correlation ID, where correlation ID is specified as an array of bytes.
JMSProducer	setJMSReplyTo(Destination replyTo) Specifies that messages sent using this JMSProducer will have their JMSReplyTo header value set to the specified Destination object.
JMSProducer	setJMSType(String type) Specifies that messages sent using this JMSProducer will have their JMSType header value set to the specified message type.
JMSProducer	setPriority(int priority) Specifies the priority of messages that are sent using this JMSProducer
JMSProducer	setProperty(String name, boolean value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified boolean value.
JMSProducer	setProperty(String name, byte value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified byte value.
JMSProducer	setProperty(String name, double value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified double value.
JMSProducer	setProperty(String name, float value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified float value.
JMSProducer	setProperty(String name, int value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified int value.
JMSProducer	setProperty(String name, long value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified long value.
JMSProducer	setProperty(String name, Object value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified Java object value.
JMSProducer	setProperty(String name, short value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified short value.
JMSProducer	setProperty(String name, String value) Specifies that messages sent using this JMSProducer will have the specified property set to the specified String value.
JMSProducer	setTimeToLive(long timeToLive) Specifies the time to live of messages that are sent using this JMSProducer.

Methods inherited from class java.lang.Object

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

Method Detail

send

public JMSProducer send(Destination destination,
                        Message message)

Description copied from interface: JMSProducer

Sends a message to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.

Specified by:

send in interface JMSProducer

Parameters:

destination - the destination to send this message to

message - the message to send

Returns:

this JMSProducer

send

public JMSProducer send(Destination destination,
                        String body)

Description copied from interface: JMSProducer

Send a TextMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.

Specified by:

send in interface JMSProducer

Parameters:

destination - the destination to send this message to

body - the body of the TextMessage that will be sent. If a null value is specified then a TextMessage with no body will be sent.

Returns:

this JMSProducer

send

public JMSProducer send(Destination destination,
                        Map<String,Object> body)

Description copied from interface: JMSProducer

Send a MapMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.

Specified by:

send in interface JMSProducer

Parameters:

destination - the destination to send this message to

body - the body of the MapMessage that will be sent. If a null value is specified then a MapMessage with no map entries will be sent.

Returns:

this JMSProducer

send

public JMSProducer send(Destination destination,
                        byte[] body)

Description copied from interface: JMSProducer

Send a BytesMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.

Specified by:

send in interface JMSProducer

Parameters:

destination - the destination to send this message to

body - the body of the BytesMessage that will be sent. If a null value is specified then a BytesMessage with no body will be sent.

Returns:

this JMSProducer

send

public JMSProducer send(Destination destination,
                        Serializable body)

Description copied from interface: JMSProducer

Send an ObjectMessage with the specified body to the specified destination, using any send options, message properties and message headers that have been defined on this JMSProducer.

Specified by:

send in interface JMSProducer

Parameters:

destination - the destination to send this message to

body - the body of the ObjectMessage that will be sent. If a null value is specified then an ObjectMessage with no body will be sent.

Returns:

this JMSProducer

setDisableMessageID

public JMSProducer setDisableMessageID(boolean value)

Description copied from interface: JMSProducer

Specifies whether message IDs may be disabled for messages that are sent using this JMSProducer

Since message IDs take some effort to create and increase a message's size, some Jakarta Messaging providers may be able to optimise message overhead if they are given a hint that the message ID is not used by an application. By calling this method, a Jakarta Messaging application enables this potential optimisation for all messages sent using this JMSProducer. If the Jakarta Messaging provider accepts this hint, these messages must have the message ID set to null; if the provider ignores the hint, the message ID must be set to its normal unique value.

Message IDs are enabled by default.

Specified by:

setDisableMessageID in interface JMSProducer

Parameters:

value - indicates whether message IDs may be disabled

Returns:

this JMSProducer

See Also:

JMSProducer.getDisableMessageID()

getDisableMessageID

public boolean getDisableMessageID()

Description copied from interface: JMSProducer

Gets an indication of whether message IDs are disabled.

Specified by:

getDisableMessageID in interface JMSProducer

Returns:

an indication of whether message IDs are disabled

See Also:

JMSProducer.setDisableMessageID(boolean)

setDisableMessageTimestamp

public JMSProducer setDisableMessageTimestamp(boolean value)

Description copied from interface: JMSProducer

Specifies whether message timestamps may be disabled for messages that are sent using this JMSProducer.

Since timestamps take some effort to create and increase a message's size, some Jakarta Messaging providers may be able to optimise message overhead if they are given a hint that the timestamp is not used by an application. By calling this method, a Jakarta Messaging application enables this potential optimisation for all messages sent using this JMSProducer. If the JMS provider accepts this hint, these messages must have the timestamp set to zero; if the provider ignores the hint, the timestamp must be set to its normal value.

Message timestamps are enabled by default.

Specified by:

setDisableMessageTimestamp in interface JMSProducer

Parameters:

value - indicates whether message timestamps may be disabled

Returns:

this JMSProducer

See Also:

JMSProducer.getDisableMessageTimestamp()

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()

Description copied from interface: JMSProducer

Gets an indication of whether message timestamps are disabled.

Specified by:

getDisableMessageTimestamp in interface JMSProducer

Returns:

an indication of whether message timestamps are disabled

See Also:

JMSProducer.setDisableMessageTimestamp(boolean)

setDeliveryMode

public JMSProducer setDeliveryMode(int deliveryMode)

Description copied from interface: JMSProducer

Specifies the delivery mode of messages that are sent using this JMSProducer

Delivery mode is set to PERSISTENT by default.

Specified by:

setDeliveryMode in interface JMSProducer

Parameters:

deliveryMode - the message delivery mode to be used; legal values are DeliveryMode.NON_PERSISTENT and DeliveryMode.PERSISTENT

Returns:

this JMSProducer

See Also:

JMSProducer.getDeliveryMode(), DeliveryMode.NON_PERSISTENT, DeliveryMode.PERSISTENT, Message.DEFAULT_DELIVERY_MODE

getDeliveryMode

public int getDeliveryMode()

Description copied from interface: JMSProducer

Returns the delivery mode of messages that are sent using this JMSProducer

Specified by:

getDeliveryMode in interface JMSProducer

Returns:

the message delivery mode

See Also:

JMSProducer.setDeliveryMode(int)

setPriority

public JMSProducer setPriority(int priority)

Description copied from interface: JMSProducer

Specifies the priority of messages that are sent using this JMSProducer

The Jakarta Messaging API defines ten levels of priority value, with 0 as the lowest priority and 9 as the highest. Clients should consider priorities 0-4 as gradations of normal priority and priorities 5-9 as gradations of expedited priority. Priority is set to 4 by default.

Specified by:

setPriority in interface JMSProducer

Parameters:

priority - the message priority to be used; must be a value between 0 and 9

Returns:

this JMSProducer

See Also:

JMSProducer.getPriority(), Message.DEFAULT_PRIORITY

getPriority

public int getPriority()

Description copied from interface: JMSProducer

Return the priority of messages that are sent using this JMSProducer

Specified by:

getPriority in interface JMSProducer

Returns:

the message priority

See Also:

JMSProducer.setPriority(int)

setTimeToLive

public JMSProducer setTimeToLive(long timeToLive)

Description copied from interface: JMSProducer

Specifies the time to live of messages that are sent using this JMSProducer. This is used to determine the expiration time of a message.

The expiration time of a message is the sum of the message's time to live and the time it is sent. For transacted sends, this is the time the client sends the message, not the time the transaction is committed.

Clients should not receive messages that have expired; however, Jakarta Messaging does not guarantee that this will not happen.

A Jakarta Messaging provider should do its best to accurately expire messages; however, Jakarta Messaging does not define the accuracy provided. It is not acceptable to simply ignore time-to-live.

Time to live is set to zero by default, which means a message never expires.

Specified by:

setTimeToLive in interface JMSProducer

Parameters:

timeToLive - the message time to live to be used, in milliseconds; a value of zero means that a message never expires.

Returns:

this JMSProducer

See Also:

JMSProducer.getTimeToLive(), Message.DEFAULT_TIME_TO_LIVE

getTimeToLive

public long getTimeToLive()

Description copied from interface: JMSProducer

Returns the time to live of messages that are sent using this JMSProducer.

Specified by:

getTimeToLive in interface JMSProducer

Returns:

the message time to live in milliseconds; a value of zero means that a message never expires.

See Also:

JMSProducer.setTimeToLive(long)

setDeliveryDelay

public JMSProducer setDeliveryDelay(long deliveryDelay)

Description copied from interface: JMSProducer

Sets the minimum length of time in milliseconds that must elapse after a message is sent before the Jakarta Messaging provider may deliver the message to a consumer.

For transacted sends, this time starts when the client sends the message, not when the transaction is committed.

deliveryDelay is set to zero by default.

Specified by:

setDeliveryDelay in interface JMSProducer

Parameters:

deliveryDelay - the delivery delay in milliseconds.

Returns:

this JMSProducer

See Also:

JMSProducer.getDeliveryDelay(), Message.DEFAULT_DELIVERY_DELAY

getDeliveryDelay

public long getDeliveryDelay()

Description copied from interface: JMSProducer

Gets the minimum length of time in milliseconds that must elapse after a message is sent before the Jakarta Messaging provider may deliver the message to a consumer.

Specified by:

getDeliveryDelay in interface JMSProducer

Returns:

the delivery delay in milliseconds.

See Also:

JMSProducer.setDeliveryDelay(long)

setAsync

public JMSProducer setAsync(CompletionListener completionListener)

Description copied from interface: JMSProducer

Specifies whether subsequent calls to send on this JMSProducer object should be synchronous or asynchronous. If the specified CompletionListener is not null then subsequent calls to send will be asynchronous. If the specified CompletionListener is null then subsequent calls to send will be synchronous. Calls to send are synchronous by default.

If a call to send is asynchronous then part of the work involved in sending the message will be performed in a separate thread and the specified CompletionListener will be notified when the operation has completed.

When the message has been successfully sent the Jakarta Messaging provider invokes the callback method onCompletion on the CompletionListener object. Only when that callback has been invoked can the application be sure that the message has been successfully sent with the same degree of confidence as if the send had been synchronous. An application which requires this degree of confidence must therefore wait for the callback to be invoked before continuing.

The following information is intended to give an indication of how an asynchronous send would typically be implemented.

In some Jakarta Messaging providers, a normal synchronous send involves sending the message to a remote Jakarta Messaging server and then waiting for an acknowledgement to be received before returning. It is expected that such a provider would implement an asynchronous send by sending the message to the remote Jakarta Messaging server and then returning without waiting for an acknowledgement. When the acknowledgement is received, the Jakarta Messaging provider would notify the application by invoking the onCompletion method on the application-specified CompletionListener object. If for some reason the acknowledgement is not received the Jakarta Messaging provider would notify the application by invoking the CompletionListener's onException method.

In those cases where the Jakarta Messaging specification permits a lower level of reliability, a normal synchronous send might not wait for an acknowledgement. In that case it is expected that an asynchronous send would be similar to a synchronous send: the Jakarta Messaging provider would send the message to the remote Jakarta Messaging server and then return without waiting for an acknowledgement. However the Jakarta Messaging provider would still notify the application that the send had completed by invoking the onCompletion method on the application-specified CompletionListener object.

It is up to the Jakarta Messaging provider to decide exactly what is performed in the calling thread and what, if anything, is performed asynchronously, so long as it satisfies the requirements given below:

Quality of service: After the send operation has completed successfully, which means that the message has been successfully sent with the same degree of confidence as if a normal synchronous send had been performed, the JMS provider must invoke the CompletionListener's onCompletion method. The CompletionListener must not be invoked earlier than this.

Exceptions: If an exception is encountered during the call to the send method then an appropriate exception should be thrown in the thread that is calling the send method. In this case the Jakarta Messaging provider must not invoke the CompletionListener's onCompletion or onException method. If an exception is encountered which cannot be thrown in the thread that is calling the send method then the Jakarta Messaging provider must call the CompletionListener's onException method. In both cases if an exception occurs it is undefined whether or not the message was successfully sent.

Message order: If the same JMSContext is used to send multiple messages then Jakarta Messaging message ordering requirements must be satisfied. This applies even if a combination of synchronous and asynchronous sends has been performed. The application is not required to wait for an asynchronous send to complete before sending the next message.

Close, commit or rollback: If the close method is called on the JMSContext then the JMS provider must block until any incomplete send operations have been completed and all CompletionListener callbacks have returned before closing the object and returning. If the session is transacted (uses a local transaction) then when the JMSContext's commit or rollback method is called the JMS provider must block until any incomplete send operations have been completed and all CompletionListener callbacks have returned before performing the commit or rollback. Incomplete sends should be allowed to complete normally unless an error occurs.

A CompletionListener callback method must not call close, commit or rollback on its own JMSContext. Doing so will cause the close, commit or rollback to throw an IllegalStateRuntimeException.

Restrictions on usage in Jakarta EE This method must not be used in a Jakarta EE EJB or web container. Doing so may cause a JMSRuntimeException to be thrown though this is not guaranteed.

Message headers Jakarta Messaging defines a number of message header fields and message properties which must be set by the "Jakarta Messaging provider on send". If the send is asynchronous these fields and properties may be accessed on the sending client only after the CompletionListener has been invoked. If the CompletionListener's onException method is called then the state of these message header fields and properties is undefined.

Restrictions on threading: Applications that perform an asynchronous send must confirm to the threading restrictions defined in JMS. This means that the session may be used by only one thread at a time.

Setting a CompletionListener does not cause the session to be dedicated to the thread of control which calls the CompletionListener. The application thread may therefore continue to use the session after performing an asynchronous send. However the CompletionListener's callback methods must not use the session if an application thread might be using the session at the same time.

Use of the CompletionListener by the Jakarta Messaging provider: A session will only invoke one CompletionListener callback method at a time. For a given JMSContext, callbacks (both onCompletion and onException) will be performed in the same order as the corresponding calls to the send method. A Jakarta Messaging provider must not invoke the CompletionListener from the thread that is calling the send method.

Restrictions on the use of the Message object: Applications which perform an asynchronous send must take account of the restriction that a Message object is designed to be accessed by one logical thread of control at a time and does not support concurrent use.

After the send method has returned, the application must not attempt to read the headers, properties or body of the Message object until the CompletionListener's onCompletion or onException method has been called. This is because the Jakarta Messaging provider may be modifying the Message object in another thread during this time. The Jakarta Messaging provider may throw an JMSException if the application attempts to access or modify the Message object after the send method has returned and before the CompletionListener has been invoked. If the Jakarta Messaging provider does not throw an exception then the behaviour is undefined.

Specified by:

setAsync in interface JMSProducer

Parameters:

completionListener - If asynchronous send behaviour is required, this should be set to a CompletionListener to be notified when the send has completed. If synchronous send behaviour is required, this should be set to null.

Returns:

this JMSProducer

See Also:

JMSProducer.getAsync(), CompletionListener

getAsync

public CompletionListener getAsync()

Description copied from interface: JMSProducer

If subsequent calls to send on this JMSProducer object have been configured to be asynchronous then this method returns the CompletionListener that has previously been configured. If subsequent calls to send have been configured to be synchronous then this method returns null.

Specified by:

getAsync in interface JMSProducer

Returns:

the CompletionListener or null

See Also:

JMSProducer.setAsync(javax.jms.CompletionListener)

setProperty

public JMSProducer setProperty(String name,
                               boolean value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified boolean value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the boolean value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getBooleanProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               byte value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified byte value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the byte value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getByteProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               short value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified short value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the short property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getShortProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               int value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified int value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the int property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getIntProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               long value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified long value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the long property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getLongProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               float value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified float value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the float property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getFloatProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               double value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified double value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the double property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getDoubleProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               String value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified String value.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the String property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getStringProperty(java.lang.String)

setProperty

public JMSProducer setProperty(String name,
                               Object value)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have the specified property set to the specified Java object value.

Note that this method works only for the objectified primitive object types (Integer, Double, Long ...) and String objects.

This will replace any property of the same name that is already set on the message being sent.

Specified by:

setProperty in interface JMSProducer

Parameters:

name - the name of the property

value - the Java object property value to set

Returns:

this JMSProducer

See Also:

JMSProducer.getObjectProperty(java.lang.String)

clearProperties

public JMSProducer clearProperties()

Description copied from interface: JMSProducer

Clears any message properties set on this JMSProducer

Specified by:

clearProperties in interface JMSProducer

Returns:

this JMSProducer

propertyExists

public boolean propertyExists(String name)

Description copied from interface: JMSProducer

Indicates whether a message property with the specified name has been set on this JMSProducer

Specified by:

propertyExists in interface JMSProducer

Parameters:

name - the name of the property

Returns:

true whether the property exists

getBooleanProperty

public boolean getBooleanProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a boolean.

Specified by:

getBooleanProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a boolean

See Also:

JMSProducer.setProperty(java.lang.String,boolean)

getByteProperty

public byte getByteProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a String.

Specified by:

getByteProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a byte

See Also:

JMSProducer.setProperty(java.lang.String,byte)

getShortProperty

public short getShortProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a short.

Specified by:

getShortProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a short

See Also:

JMSProducer.setProperty(java.lang.String,short)

getIntProperty

public int getIntProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a int.

Specified by:

getIntProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a int

See Also:

JMSProducer.setProperty(java.lang.String,int)

getLongProperty

public long getLongProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a long.

Specified by:

getLongProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a long

See Also:

JMSProducer.setProperty(java.lang.String,long)

getFloatProperty

public float getFloatProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a float.

Specified by:

getFloatProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a float

See Also:

JMSProducer.setProperty(java.lang.String,float)

getDoubleProperty

public double getDoubleProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a double.

Specified by:

getDoubleProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a double

See Also:

JMSProducer.setProperty(java.lang.String,double)

getStringProperty

public String getStringProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to a String.

Specified by:

getStringProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the property value, converted to a boolean; if there is no property by this name, a null value is returned

See Also:

JMSProducer.setProperty(java.lang.String,String)

getObjectProperty

public Object getObjectProperty(String name)

Description copied from interface: JMSProducer

Returns the message property with the specified name that has been set on this JMSProducer, converted to objectified format.

This method can be used to return, in objectified format, an object that has been stored as a property in the message with the equivalent setObjectProperty method call, or its equivalent primitive settypeProperty method.

Specified by:

getObjectProperty in interface JMSProducer

Parameters:

name - the name of the property

Returns:

the Java object property value with the specified name, in objectified format (for example, if the property was set as an int, an Integer is returned); if there is no property by this name, a null value is returned

See Also:

JMSProducer.setProperty(java.lang.String,java.lang.Object)

getPropertyNames

public Set<String> getPropertyNames()

Description copied from interface: JMSProducer

Returns an unmodifiable Set view of the names of all the message properties that have been set on this JMSProducer.

Note that Jakarta Messaging standard header fields are not considered properties and are not returned in this Set.

The set is backed by the JMSProducer, so changes to the map are reflected in the set. However the set may not be modified. Attempts to modify the returned collection, whether directly or via its iterator, will result in an java.lang.UnsupportedOperationException. Its behaviour matches that defined in the java.util.Collections method unmodifiableSet.

Specified by:

getPropertyNames in interface JMSProducer

Returns:

a Set containing the names of all the message properties that have been set on this JMSProducer

See Also:

Collections.unmodifiableSet(java.util.Set<? extends T>)

setJMSCorrelationIDAsBytes

public JMSProducer setJMSCorrelationIDAsBytes(byte[] correlationID)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have their JMSCorrelationID header value set to the specified correlation ID, where correlation ID is specified as an array of bytes.

This will override any JMSCorrelationID header value that is already set on the message being sent.

The array is copied before the method returns, so future modifications to the array will not alter the value in this JMSProducer.

If a provider supports the native concept of correlation ID, a Jakarta Messaging client may need to assign specific JMSCorrelationID values to match those expected by native messaging clients. Jakarta Messaging providers without native correlation ID values are not required to support this method and its corresponding get method; their implementation may throw a java.lang.UnsupportedOperationException.

The use of a byte[] value for JMSCorrelationID is non-portable.

Specified by:

setJMSCorrelationIDAsBytes in interface JMSProducer

Parameters:

correlationID - the correlation ID value as an array of bytes

Returns:

this JMSProducer

See Also:

JMSProducer.setJMSCorrelationID(String), JMSProducer.getJMSCorrelationID(), JMSProducer.getJMSCorrelationIDAsBytes()

getJMSCorrelationIDAsBytes

public byte[] getJMSCorrelationIDAsBytes()

Description copied from interface: JMSProducer

Returns the JMSCorrelationID header value that has been set on this JMSProducer, as an array of bytes.

The use of a byte[] value for JMSCorrelationID is non-portable.

Specified by:

getJMSCorrelationIDAsBytes in interface JMSProducer

Returns:

the correlation ID as an array of bytes

See Also:

JMSProducer.setJMSCorrelationID(String), JMSProducer.getJMSCorrelationID(), JMSProducer.setJMSCorrelationIDAsBytes(byte[])

setJMSCorrelationID

public JMSProducer setJMSCorrelationID(String correlationID)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have their JMSCorrelationID header value set to the specified correlation ID, where correlation ID is specified as a String.

This will override any JMSCorrelationID header value that is already set on the message being sent.

A client can use the JMSCorrelationID header field to link one message with another. A typical use is to link a response message with its request message.

JMSCorrelationID can hold one of the following:

• A provider-specific message ID
• An application-specific String
• A provider-native byte[] value

Since each message sent by a Jakarta Messaging provider is assigned a message ID value, it is convenient to link messages via message ID. All message ID values must start with the 'ID:' prefix.

In some cases, an application (made up of several clients) needs to use an application-specific value for linking messages. For instance, an application may use JMSCorrelationID to hold a value referencing some external information. Application-specified values must not start with the 'ID:' prefix; this is reserved for provider-generated message ID values.

If a provider supports the native concept of correlation ID, a Jakarta Messaging client may need to assign specific JMSCorrelationID values to match those expected by clients that do not use the Jakarta Messaging API. A byte[] value is used for this purpose. Jakarta Messaging providers without native correlation ID values are not required to support byte[] values. The use of a byte[] value for JMSCorrelationID is non-portable.

Specified by:

setJMSCorrelationID in interface JMSProducer

Parameters:

correlationID - the message ID of a message being referred to

Returns:

this JMSProducer

See Also:

JMSProducer.getJMSCorrelationID(), JMSProducer.getJMSCorrelationIDAsBytes(), JMSProducer.setJMSCorrelationIDAsBytes(byte[])

getJMSCorrelationID

public String getJMSCorrelationID()

Description copied from interface: JMSProducer

Returns the JMSCorrelationID header value that has been set on this JMSProducer, as a String.

This method is used to return correlation ID values that are either provider-specific message IDs or application-specific String values.

Specified by:

getJMSCorrelationID in interface JMSProducer

Returns:

the correlation ID of a message as a String

See Also:

JMSProducer.setJMSCorrelationID(String), JMSProducer.getJMSCorrelationIDAsBytes(), JMSProducer.setJMSCorrelationIDAsBytes(byte[])

setJMSType

public JMSProducer setJMSType(String type)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have their JMSType header value set to the specified message type.

This will override any JMSType header value that is already set on the message being sent.

Some Jakarta Messaging providers use a message repository that contains the definitions of messages sent by applications. The JMSType header field may reference a message's definition in the provider's repository.

The Jakarta Messaging API does not define a standard message definition repository, nor does it define a naming policy for the definitions it contains.

Some messaging systems require that a message type definition for each application message be created and that each message specify its type. In order to work with such Jakarta Messaging providers, Jakarta Messaging clients should assign a value to JMSType, whether the application makes use of it or not. This ensures that the field is properly set for those providers that require it.

To ensure portability, Jakarta Messaging clients should use symbolic values for JMSType that can be configured at installation time to the values defined in the current provider's message repository. If string literals are used, they may not be valid type names for some Jakarta Messaging providers.

Specified by:

setJMSType in interface JMSProducer

Parameters:

type - the message type

Returns:

this JMSProducer

See Also:

JMSProducer.getJMSType()

getJMSType

public String getJMSType()

Description copied from interface: JMSProducer

Returns the JMSType header value that has been set on this JMSProducer.

Specified by:

getJMSType in interface JMSProducer

Returns:

the message type

See Also:

JMSProducer.setJMSType(String)

setJMSReplyTo

public JMSProducer setJMSReplyTo(Destination replyTo)

Description copied from interface: JMSProducer

Specifies that messages sent using this JMSProducer will have their JMSReplyTo header value set to the specified Destination object.

This will override any JMSReplyTo header value that is already set on the message being sent.

The JMSReplyTo header field contains the destination where a reply to the current message should be sent. If it is null, no reply is expected. The destination may be either a Queue object or a Topic object.

Messages sent with a null JMSReplyTo value may be a notification of some event, or they may just be some data the sender thinks is of interest.

Messages with a JMSReplyTo value typically expect a response. A response is optional; it is up to the client to decide. These messages are called requests. A message sent in response to a request is called a reply.

In some cases a client may wish to match a request it sent earlier with a reply it has just received. The client can use the JMSCorrelationID header field for this purpose.

Specified by:

setJMSReplyTo in interface JMSProducer

Parameters:

replyTo - Destination to which to send a response to this message

Returns:

this JMSProducer

See Also:

JMSProducer.getJMSReplyTo()

getJMSReplyTo

public Destination getJMSReplyTo()

Description copied from interface: JMSProducer

Returns the JMSReplyTo header value that has been set on this JMSProducer.

Specified by:

getJMSReplyTo in interface JMSProducer

Returns:

Destination the JMSReplyTo header value

See Also:

JMSProducer.setJMSReplyTo(Destination)