public class MultiSessionConsumer extends MessageConsumerListener implements jakarta.jms.ConnectionConsumer
Modifier and Type | Class and Description |
---|---|
(package private) class |
MultiSessionConsumer.MessageDispatcher |
MessageConsumerListener.Status
Modifier and Type | Field and Description |
---|---|
private Connection |
cnx |
private static Logger |
logger |
private int |
maxMsgs |
private MultiSessionConsumer.MessageDispatcher |
msgDispatcher |
private int |
nbActivatedListeners
Number of simultaneously activated
listeners.
|
private Queue |
repliesIn |
private jakarta.jms.ServerSessionPool |
sessPool |
Constructor and Description |
---|
MultiSessionConsumer(boolean queueMode,
boolean durable,
String selector,
String destName,
String targetName,
jakarta.jms.ServerSessionPool sessionPool,
int queueMessageReadMax,
int topicActivationThreshold,
int topicPassivationThreshold,
int topicAckBufferMax,
RequestMultiplexer reqMultiplexer,
Connection connection,
int maxMessages) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkSessionThread() |
void |
close()
Called by Session.
|
jakarta.jms.ServerSessionPool |
getServerSessionPool() |
void |
onMessage(Message msg,
jakarta.jms.MessageListener listener,
int ackMode) |
void |
pushMessages(ConsumerMessages cm)
Pushes the received messages.
|
ack, activateListener, activateMessageInput, addMessageListener, errorReceived, getDestName, getMessageListener, getMessageListenersSize, getQueueMode, getStatus, getTargetName, isClosed, onMessage, passivateMessageInput, removeMessageListener, replyAborted, replyReceived, setStatus, start
private static final Logger logger
private jakarta.jms.ServerSessionPool sessPool
private Connection cnx
private int maxMsgs
private Queue repliesIn
private int nbActivatedListeners
private MultiSessionConsumer.MessageDispatcher msgDispatcher
MultiSessionConsumer(boolean queueMode, boolean durable, String selector, String destName, String targetName, jakarta.jms.ServerSessionPool sessionPool, int queueMessageReadMax, int topicActivationThreshold, int topicPassivationThreshold, int topicAckBufferMax, RequestMultiplexer reqMultiplexer, Connection connection, int maxMessages)
consumer
- listener
- ackMode
- queueMessageReadMax
- topicActivationThreshold
- topicPassivationThreshold
- topicAckBufferMax
- reqMultiplexer
- public void pushMessages(ConsumerMessages cm) throws jakarta.jms.JMSException
MessageConsumerListener
pushMessages
in class MessageConsumerListener
jakarta.jms.JMSException
public jakarta.jms.ServerSessionPool getServerSessionPool() throws jakarta.jms.JMSException
getServerSessionPool
in interface jakarta.jms.ConnectionConsumer
jakarta.jms.JMSException
public void close() throws jakarta.jms.JMSException
MessageConsumerListener
close
in interface jakarta.jms.ConnectionConsumer
close
in class MessageConsumerListener
jakarta.jms.JMSException
public void onMessage(Message msg, jakarta.jms.MessageListener listener, int ackMode) throws jakarta.jms.JMSException
onMessage
in class MessageConsumerListener
jakarta.jms.JMSException
protected boolean checkSessionThread()
checkSessionThread
in class MessageConsumerListener
Copyright © 2023 ScalAgent D.T.. All rights reserved.