Package io.micronaut.jms.templates

Class JmsConsumer

java.lang.Object

io.micronaut.jms.templates.JmsConsumer

public class JmsConsumer
extends Object

Helper class that receives messages, configuring JMS connections, sessions, etc. for you. TODO rename with JmsProducer

Since:

1.0.0

Author:

Elliott Pope

Constructor Summary

Constructors

Constructor	Description
JmsConsumer(JMSDestinationType type, JMSConnectionPool connectionPool, Deserializer deserializer)
JmsConsumer(JMSDestinationType type, JMSConnectionPool connectionPool, Deserializer deserializer, boolean sessionTransacted, int sessionAcknowledgeMode)

Method Summary

Modifier and Type	Method	Description
jakarta.jms.Message	receive(@NonNull String destination)	Receives a Message from the broker.
<T> T	receive(@NonNull String destination, Class<T> clazz)	Receives a Message from the broker and and converts it to an instance of type <T>.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

JmsConsumer

public JmsConsumer(JMSDestinationType type,
 JMSConnectionPool connectionPool,
 Deserializer deserializer)

JmsConsumer

public JmsConsumer(JMSDestinationType type,
 JMSConnectionPool connectionPool,
 Deserializer deserializer,
 boolean sessionTransacted,
 int sessionAcknowledgeMode)

Method Details

receive

public <T> T receive(@NonNull
 @NonNull String destination,
 Class<T> clazz)

Receives a Message from the broker and and converts it to an instance of type <T>.

Type Parameters:

T - the class type

Parameters:

destination - the queue or topic name

clazz - the class

Returns:

the message from the broker as an object instance of type <T>.

receive

public jakarta.jms.Message receive(@NonNull
 @NonNull String destination)

Receives a Message from the broker.

Parameters:

destination - the queue or topic name

Returns:

the message

toString

public String toString()

Overrides:

toString in class Object