public class MultiSessionConsumer extends MessageConsumerListener implements javax.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 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 javax.jms.ServerSessionPool |
sessPool |
Constructor and Description |
---|
MultiSessionConsumer(boolean queueMode,
boolean durable,
String selector,
String destName,
String targetName,
javax.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.
|
javax.jms.ServerSessionPool |
getServerSessionPool() |
void |
onMessage(Message msg,
javax.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 org.objectweb.util.monolog.api.Logger logger
private javax.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, javax.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 javax.jms.JMSException
MessageConsumerListener
pushMessages
in class MessageConsumerListener
javax.jms.JMSException
public javax.jms.ServerSessionPool getServerSessionPool() throws javax.jms.JMSException
getServerSessionPool
in interface javax.jms.ConnectionConsumer
javax.jms.JMSException
public void close() throws javax.jms.JMSException
MessageConsumerListener
close
in interface javax.jms.ConnectionConsumer
close
in class MessageConsumerListener
javax.jms.JMSException
public void onMessage(Message msg, javax.jms.MessageListener listener, int ackMode) throws javax.jms.JMSException
onMessage
in class MessageConsumerListener
javax.jms.JMSException
protected boolean checkSessionThread()
checkSessionThread
in class MessageConsumerListener
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.