io.micronaut.jms.templates

Class JmsConsumer

java.lang.Object

io.micronaut.jms.templates.JmsConsumer

public class JmsConsumer
extends java.lang.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 and 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 and Description
javax.jms.Message	receive(java.lang.String destination) Receives a Message from the broker.
<T> T	receive(java.lang.String destination, java.lang.Class<T> clazz) Receives a Message from the broker and and converts it to an instance of type <T>.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsConsumer

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

JmsConsumer

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

Method Detail

receive

public <T> T receive(@NonNull
                     java.lang.String destination,
                     java.lang.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 javax.jms.Message receive(@NonNull
                                 java.lang.String destination)

Receives a Message from the broker.

Parameters:

destination - the queue or topic name

Returns:

the message

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object