org.apache.qpid.client
Class BasicMessageConsumer_0_8

java.lang.Object
  extended by org.apache.qpid.client.Closeable
      extended by org.apache.qpid.client.BasicMessageConsumer<UnprocessedMessage_0_8>
          extended by 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
 
Fields inherited from class org.apache.qpid.client.Closeable
_closed, _closing
 
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)
           
 
Method Summary
 AbstractJMSMessage createJMSMessageFromUnprocessedMessage(AMQMessageDelegateFactory delegateFactory, UnprocessedMessage_0_8 messageFrame)
           
(package private)  Message receiveBrowse()
           
(package private)  void sendCancel()
           
 
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 org.apache.qpid.client.Closeable
checkNotClosed, isClosed, isClosing
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_logger

protected final org.slf4j.Logger _logger
Constructor Detail

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
Method Detail

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