Class JMSMessageListenerWrapper

java.lang.Object

org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.MessageHandler

public class JMSMessageListenerWrapper
extends Object
implements org.apache.activemq.artemis.api.core.client.MessageHandler

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JMSMessageListenerWrapper(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, org.apache.activemq.artemis.api.core.client.ClientConsumer consumer, jakarta.jms.MessageListener listener, int ackMode)

Method Summary

Modifier and Type	Method	Description
void	onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message)	In this method we apply the JMS acknowledgement and redelivery semantics as per JMS spec
void	onMessageExpired(org.apache.activemq.artemis.api.core.client.ClientMessage message)

Methods inherited from class Object

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

Constructor Details

JMSMessageListenerWrapper

protected JMSMessageListenerWrapper(ConnectionFactoryOptions options,
 ActiveMQConnection connection,
 ActiveMQSession session,
 org.apache.activemq.artemis.api.core.client.ClientConsumer consumer,
 jakarta.jms.MessageListener listener,
 int ackMode)

Method Details

onMessage

public void onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message)

In this method we apply the JMS acknowledgement and redelivery semantics as per JMS spec

Specified by:

onMessage in interface org.apache.activemq.artemis.api.core.client.MessageHandler

onMessageExpired

public void onMessageExpired(org.apache.activemq.artemis.api.core.client.ClientMessage message)

Specified by:

onMessageExpired in interface org.apache.activemq.artemis.api.core.client.MessageHandler