Package 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 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	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	Description
void	send(@NonNull String destination, @NonNull javax.jms.Message message, @io.micronaut.core.annotation.NonNull long timeToLive, MessageHeader... headers)	Sends the given message to the destination with the given headers.
void	send(@NonNull String destination, T body, @io.micronaut.core.annotation.NonNull long timeToLive, MessageHeader... headers)	Creates a Message from the body and sends it to the destination with the headers.
void	send(@NonNull javax.jms.Destination destination, @NonNull javax.jms.Message message, @io.micronaut.core.annotation.NonNull long timeToLive, MessageHeader... headers)	Sends the given message to the destination with the given headers.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

JmsProducer

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

JmsProducer

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

Method Details

send

public void send(@NonNull
 @NonNull String destination,
 @NonNull
 T body,
 @NonNull
 @io.micronaut.core.annotation.NonNull long timeToLive,
 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

timeToLive - time to live parameter in milliseconds

headers - optional headers

send

public void send(@NonNull
 @NonNull String destination,
 @NonNull
 @NonNull javax.jms.Message message,
 @NonNull
 @io.micronaut.core.annotation.NonNull long timeToLive,
 MessageHeader... headers)

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

Parameters:

destination - the queue or topic name

message - the message

timeToLive - time to live parameter in milliseconds

headers - optional headers

send

public void send(@NonNull
 @NonNull javax.jms.Destination destination,
 @NonNull
 @NonNull javax.jms.Message message,
 @NonNull
 @io.micronaut.core.annotation.NonNull long timeToLive,
 MessageHeader... headers)

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

Parameters:

destination - the queue or topic name

message - the message

timeToLive - time to live parameter in milliseconds

headers - optional headers

toString

public String toString()

Overrides:

toString in class Object