org.apache.qpid.client
Class BasicMessageConsumer_0_8
java.lang.Object
org.apache.qpid.client.Closeable
org.apache.qpid.client.BasicMessageConsumer<UnprocessedMessage_0_8>
org.apache.qpid.client.BasicMessageConsumer_0_8
- All Implemented Interfaces:
- MessageConsumer
public class BasicMessageConsumer_0_8
- extends BasicMessageConsumer<UnprocessedMessage_0_8>
Field Summary |
protected org.slf4j.Logger |
_logger
|
Fields inherited from class org.apache.qpid.client.BasicMessageConsumer |
_acknowledgeMode, _channelId, _connection, _consumerTag, _destination, _exclusive, _messageFactory, _messageSelector, _protocolHandler, _session, _synchronousQueue |
Constructor Summary |
protected |
BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
Methods inherited from class org.apache.qpid.client.BasicMessageConsumer |
acknowledgeDelivered, addBindingKey, clearReceiveQueue, close, close, debugIdentity, drainReceiverQueueAndRetrieveDeliveryTags, failedOverPost, failedOverPre, getAcknowledgeMode, getArguments, getConsumerTag, getDestination, getLastDelivered, getMessageFromQueue, getMessageListener, getMessageSelector, getPrefetch, getPrefetchHigh, getPrefetchLow, getQueuename, getSession, isAutoClose, isExclusive, isMessageListenerSet, isNoConsume, isNoLocal, isReceiving, markClosed, notifyCloseMessage, notifyError, notifyMessage, notifyMessage, postDeliver, preApplicationProcessing, preDeliver, receive, receive, receiveNoWait, rollback, rollbackPendingMessages, setConsumerTag, setMessageListener, setQueuename |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_logger
protected final org.slf4j.Logger _logger
BasicMessageConsumer_0_8
protected BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
throws JMSException
- Throws:
JMSException
sendCancel
void sendCancel()
throws org.apache.qpid.AMQException,
FailoverException
- Specified by:
sendCancel
in class BasicMessageConsumer<UnprocessedMessage_0_8>
- Throws:
org.apache.qpid.AMQException
FailoverException
createJMSMessageFromUnprocessedMessage
public AbstractJMSMessage createJMSMessageFromUnprocessedMessage(AMQMessageDelegateFactory delegateFactory,
UnprocessedMessage_0_8 messageFrame)
throws Exception
- Specified by:
createJMSMessageFromUnprocessedMessage
in class BasicMessageConsumer<UnprocessedMessage_0_8>
- Throws:
Exception
receiveBrowse
Message receiveBrowse()
throws JMSException
- Specified by:
receiveBrowse
in class BasicMessageConsumer<UnprocessedMessage_0_8>
- Throws:
JMSException
Licensed to the Apache Software Foundation