org.hornetq.core.server.impl

Class ServerConsumerImpl

java.lang.Object

org.hornetq.core.server.impl.ServerConsumerImpl

All Implemented Interfaces:

Consumer, ServerConsumer, ReadyListener

public class ServerConsumerImpl
extends Object
implements ServerConsumer, ReadyListener

Concrete implementation of a ClientConsumer.

Version:

$Revision: 3783 $ $Id: ServerConsumerImpl.java 3783 2008-02-25 12:15:14Z timfox $

Author:

Tim Fox, Jeff Mesnil, Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(boolean autoCommitAcks, Transaction tx, long messageID)
LinkedList<MessageReference>	cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx)
void	close(boolean failed)
String	debug()
void	forceDelivery(long sequence) Prompt delivery and send a "forced delivery" message to the consumer.
AtomicInteger	getAvailableCredits() To be used on tests only
String	getConnectionID()
long	getCreationTime()
Filter	getFilter()
long	getID()
Queue	getQueue()
String	getSessionID()
HandleStatus	handle(MessageReference ref)
void	individualAcknowledge(boolean autoCommitAcks, Transaction tx, long messageID)
boolean	isBrowseOnly()
void	readyForWriting(boolean ready)
void	receiveCredits(int credits)
MessageReference	removeReferenceByID(long messageID)
void	setStarted(boolean started)
void	setTransferring(boolean transferring)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServerConsumerImpl

public ServerConsumerImpl(long id,
                  ServerSession session,
                  QueueBinding binding,
                  Filter filter,
                  boolean started,
                  boolean browseOnly,
                  StorageManager storageManager,
                  SessionCallback callback,
                  boolean preAcknowledge,
                  boolean strictUpdateDeliveryCount,
                  ManagementService managementService)
                   throws Exception

Throws:

Exception

Method Detail

debug

public String debug()

Specified by:

debug in interface Consumer

getID

public long getID()

Specified by:

getID in interface ServerConsumer

isBrowseOnly

public boolean isBrowseOnly()

Specified by:

isBrowseOnly in interface ServerConsumer

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface ServerConsumer

getConnectionID

public String getConnectionID()

Specified by:

getConnectionID in interface ServerConsumer

getSessionID

public String getSessionID()

Specified by:

getSessionID in interface ServerConsumer

handle

public HandleStatus handle(MessageReference ref)
                    throws Exception

Specified by:

handle in interface Consumer

Throws:

Exception

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Consumer

close

public void close(boolean failed)
           throws Exception

Specified by:

close in interface ServerConsumer

Throws:

Exception

forceDelivery

public void forceDelivery(long sequence)

Prompt delivery and send a "forced delivery" message to the consumer. When the consumer receives such a "forced delivery" message, it discards it and knows that there are no other messages to be delivered.

Specified by:

forceDelivery in interface ServerConsumer

cancelRefs

public LinkedList<MessageReference> cancelRefs(boolean failed,
                                      boolean lastConsumedAsDelivered,
                                      Transaction tx)
                                        throws Exception

Specified by:

cancelRefs in interface ServerConsumer

Throws:

Exception

setStarted

public void setStarted(boolean started)

Specified by:

setStarted in interface ServerConsumer

setTransferring

public void setTransferring(boolean transferring)

Specified by:

setTransferring in interface ServerConsumer

receiveCredits

public void receiveCredits(int credits)
                    throws Exception

Specified by:

receiveCredits in interface ServerConsumer

Throws:

Exception

getQueue

public Queue getQueue()

Specified by:

getQueue in interface ServerConsumer

acknowledge

public void acknowledge(boolean autoCommitAcks,
               Transaction tx,
               long messageID)
                 throws Exception

Specified by:

acknowledge in interface ServerConsumer

Throws:

Exception

individualAcknowledge

public void individualAcknowledge(boolean autoCommitAcks,
                         Transaction tx,
                         long messageID)
                           throws Exception

Specified by:

individualAcknowledge in interface ServerConsumer

Throws:

Exception

removeReferenceByID

public MessageReference removeReferenceByID(long messageID)
                                     throws Exception

Specified by:

removeReferenceByID in interface ServerConsumer

Throws:

Exception

readyForWriting

public void readyForWriting(boolean ready)

Specified by:

readyForWriting in interface ReadyListener

getAvailableCredits

public AtomicInteger getAvailableCredits()

To be used on tests only