Package org.apache.activemq.artemis.jms.client

Class JMSMessageListenerWrapper

java.lang.Object

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

All Implemented Interfaces:

MessageHandler

public class JMSMessageListenerWrapper
extends Object
implements MessageHandler

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JMSMessageListenerWrapper(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, ClientConsumer consumer, MessageListener listener, int ackMode)

Method Summary

Modifier and Type	Method	Description
void	onMessage(ClientMessage message)	In this method we apply the JMS acknowledgement and redelivery semantics as per JMS spec
void	onMessageExpired(ClientMessage message)	Notifies the MessageHandler that an expired message has been received.

Methods inherited from class java.lang.Object

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

Constructor Details

JMSMessageListenerWrapper

protected JMSMessageListenerWrapper(ConnectionFactoryOptions options,
 ActiveMQConnection connection,
 ActiveMQSession session,
 ClientConsumer consumer,
 MessageListener listener,
 int ackMode)

Method Details

onMessage

public void onMessage(ClientMessage message)

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

Specified by:

onMessage in interface MessageHandler

Parameters:

message - a message

onMessageExpired

public void onMessageExpired(ClientMessage message)

Description copied from interface: MessageHandler

Notifies the MessageHandler that an expired message has been received.

Specified by:

onMessageExpired in interface MessageHandler

Parameters:

message - a message