public class MultiSessionConsumer extends MessageConsumerListener implements 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 org.objectweb.util.monolog.api.Logger |
logger |
private int |
maxMsgs |
private MultiSessionConsumer.MessageDispatcher |
msgDispatcher |
private int |
nbActivatedListeners
Number of simultaneously activated
listeners.
|
private Queue |
repliesIn |
private ServerSessionPool |
sessPool |
Constructor and Description |
---|
MultiSessionConsumer(boolean queueMode,
boolean durable,
String selector,
String destName,
String targetName,
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.
|
ServerSessionPool |
getServerSessionPool() |
void |
onMessage(Message msg,
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 org.objectweb.util.monolog.api.Logger logger
private 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, 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 JMSException
MessageConsumerListener
pushMessages
in class MessageConsumerListener
JMSException
public ServerSessionPool getServerSessionPool() throws JMSException
getServerSessionPool
in interface ConnectionConsumer
JMSException
public void close() throws JMSException
MessageConsumerListener
close
in interface ConnectionConsumer
close
in class MessageConsumerListener
JMSException
public void onMessage(Message msg, MessageListener listener, int ackMode) throws JMSException
onMessage
in class MessageConsumerListener
JMSException
protected boolean checkSessionThread()
checkSessionThread
in class MessageConsumerListener
Copyright © 2019 ScalAgent D.T.. All rights reserved.