public class BasicMessageConsumer_0_8 extends BasicMessageConsumer<UnprocessedMessage_0_8>
Modifier | Constructor and Description |
---|---|
protected |
BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession_0_8 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_8 messageFrame) |
RejectBehaviour |
getRejectBehaviour() |
AMQSession_0_8 |
getSession() |
javax.jms.Message |
receive(long l) |
javax.jms.Message |
receiveNoWait() |
addBindingKey, clearReceiveQueue, close, close, debugIdentity, drainReceiverQueueAndRetrieveDeliveryTags, failedOverPost, failedOverPre, getAcknowledgeMode, getArguments, getChannelId, getConnection, getConsumerTag, getDestination, getMessageFactory, getMessageFromQueue, getMessageListener, getMessageSelector, getMessageSelectorFilter, getPrefetch, getPrefetchHigh, getPrefetchLow, getQueuename, getSynchronousQueue, isAutoClose, isBrowseOnly, isDurableSubscriber, isExclusive, isMessageListenerSet, isNoLocal, isReceiving, markAsDurableSubscriber, notifyCloseMessage, notifyMessage, preDeliver, receive, setConsumerTag, setDestination, setMessageListener, setQueuename
checkNotClosed, isClosed, isClosing, setClosed, setClosing
protected BasicMessageConsumer_0_8(int channelId, AMQConnection connection, AMQDestination destination, String messageSelector, boolean noLocal, MessageFactoryRegistry messageFactory, AMQSession_0_8 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 AMQSession_0_8 getSession()
getSession
in class BasicMessageConsumer<UnprocessedMessage_0_8>
public AbstractJMSMessage createJMSMessageFromUnprocessedMessage(AMQMessageDelegateFactory delegateFactory, UnprocessedMessage_0_8 messageFrame) throws Exception
createJMSMessageFromUnprocessedMessage
in class BasicMessageConsumer<UnprocessedMessage_0_8>
Exception
public RejectBehaviour getRejectBehaviour()
public javax.jms.Message receive(long l) throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
receive
in class BasicMessageConsumer<UnprocessedMessage_0_8>
javax.jms.JMSException
public javax.jms.Message receiveNoWait() throws javax.jms.JMSException
receiveNoWait
in interface javax.jms.MessageConsumer
receiveNoWait
in class BasicMessageConsumer<UnprocessedMessage_0_8>
javax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.