io.micronaut.jms.templates

Class JmsProducer<T>

java.lang.Object

io.micronaut.jms.templates.JmsProducer<T>

Type Parameters:

T - the message type

public class JmsProducer<T>
extends java.lang.Object

Helper class that sends messages, configuring JMS connections, sessions, etc. for you.

TODO rename, too similar to JMSProducer

Since:

1.0.0

Author:

Elliott Pope

Constructor Summary

Constructors

Constructor and Description
JmsProducer(JMSDestinationType type, JMSConnectionPool connectionPool, Serializer serializer)
JmsProducer(JMSDestinationType type, JMSConnectionPool connectionPool, Serializer serializer, boolean sessionTransacted, int sessionAcknowledgeMode)

Method Summary

Modifier and Type	Method and Description
void	send(javax.jms.Destination destination, javax.jms.Message message, MessageHeader... headers) Sends the given message to the destination with the given headers.
void	send(java.lang.String destination, javax.jms.Message message, MessageHeader... headers) Sends the given message to the destination with the given headers.
void	send(java.lang.String destination, T body, MessageHeader... headers) Creates a Message from the body and sends it to the destination with the headers.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsProducer

public JmsProducer(JMSDestinationType type,
                   JMSConnectionPool connectionPool,
                   Serializer serializer)

JmsProducer

public JmsProducer(JMSDestinationType type,
                   JMSConnectionPool connectionPool,
                   Serializer serializer,
                   boolean sessionTransacted,
                   int sessionAcknowledgeMode)

Method Detail

send

public void send(@NonNull
                 java.lang.String destination,
                 @NonNull
                 T body,
                 MessageHeader... headers)

Creates a Message from the body and sends it to the destination with the headers.

Parameters:

destination - the queue or topic name

body - the body

headers - optional headers

send

public void send(@NonNull
                 java.lang.String destination,
                 @NonNull
                 javax.jms.Message message,
                 MessageHeader... headers)

Sends the given message to the destination with the given headers.

Parameters:

destination - the queue or topic name

message - the message

headers - optional headers

send

public void send(@NonNull
                 javax.jms.Destination destination,
                 @NonNull
                 javax.jms.Message message,
                 MessageHeader... headers)

Sends the given message to the destination with the given headers.

Parameters:

destination - the queue or topic name

message - the message

headers - optional headers

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object