public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedMessage_0_10>
Modifier | Constructor and Description |
---|---|
protected |
BasicMessageConsumer_0_10(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession<?,?> session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
Modifier and Type | Method and Description |
---|---|
AbstractJMSMessage |
createJMSMessageFromUnprocessedMessage(AMQMessageDelegateFactory delegateFactory,
UnprocessedMessage_0_10 msg) |
void |
failedOverPost() |
String |
getConsumerTagString() |
Object |
getMessageFromQueue(long l)
When messages are not prefetched we need to request a message from the
broker.
|
void |
notifyMessage(AbstractJMSMessage jmsMessage)
This is invoked by the session thread when emptying the session message queue.
|
protected void |
preDeliver(AbstractJMSMessage jmsMsg) |
javax.jms.Message |
receive(long l) |
javax.jms.Message |
receiveNoWait() |
void |
setConsumerTag(int consumerTag) |
void |
setMessageListener(javax.jms.MessageListener messageListener) |
addBindingKey, clearReceiveQueue, close, close, debugIdentity, drainReceiverQueueAndRetrieveDeliveryTags, failedOverPre, getAcknowledgeMode, getArguments, getChannelId, getConnection, getConsumerTag, getDestination, getMessageFactory, getMessageListener, getMessageSelector, getMessageSelectorFilter, getPrefetch, getPrefetchHigh, getPrefetchLow, getQueuename, getSession, getSynchronousQueue, isAutoClose, isBrowseOnly, isDurableSubscriber, isExclusive, isMessageListenerSet, isNoLocal, isReceiving, markAsDurableSubscriber, notifyCloseMessage, receive, setDestination, setQueuename
checkNotClosed, isClosed, isClosing, setClosed, setClosing
protected BasicMessageConsumer_0_10(int channelId, AMQConnection connection, AMQDestination destination, String messageSelector, boolean noLocal, MessageFactoryRegistry messageFactory, AMQSession<?,?> session, Map<String,Object> rawSelector, int prefetchHigh, int prefetchLow, boolean exclusive, int acknowledgeMode, boolean browseOnly, boolean autoClose) throws javax.jms.JMSException
javax.jms.JMSException
public void setConsumerTag(int consumerTag)
setConsumerTag
in class BasicMessageConsumer<UnprocessedMessage_0_10>
public String getConsumerTagString()
public void notifyMessage(AbstractJMSMessage jmsMessage)
notifyMessage
in class BasicMessageConsumer<UnprocessedMessage_0_10>
jmsMessage
- this message has already been processed so can't redo preDeliverprotected void preDeliver(AbstractJMSMessage jmsMsg)
preDeliver
in class BasicMessageConsumer<UnprocessedMessage_0_10>
public AbstractJMSMessage createJMSMessageFromUnprocessedMessage(AMQMessageDelegateFactory delegateFactory, UnprocessedMessage_0_10 msg) throws Exception
createJMSMessageFromUnprocessedMessage
in class BasicMessageConsumer<UnprocessedMessage_0_10>
Exception
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.MessageConsumer
setMessageListener
in class BasicMessageConsumer<UnprocessedMessage_0_10>
javax.jms.JMSException
public void failedOverPost()
failedOverPost
in class BasicMessageConsumer<UnprocessedMessage_0_10>
public Object getMessageFromQueue(long l) throws InterruptedException
getMessageFromQueue
in class BasicMessageConsumer<UnprocessedMessage_0_10>
l
- InterruptedException
public javax.jms.Message receive(long l) throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
receive
in class BasicMessageConsumer<UnprocessedMessage_0_10>
javax.jms.JMSException
public javax.jms.Message receiveNoWait() throws javax.jms.JMSException
receiveNoWait
in interface javax.jms.MessageConsumer
receiveNoWait
in class BasicMessageConsumer<UnprocessedMessage_0_10>
javax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.