org.apache.qpid.server.virtualhost

Class AbstractSystemMessageSource.Consumer

java.lang.Object

org.apache.qpid.server.virtualhost.AbstractSystemMessageSource.Consumer

All Implemented Interfaces:

ConsumerImpl

Enclosing class:

AbstractSystemMessageSource

protected class AbstractSystemMessageSource.Consumer
extends Object
implements ConsumerImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.server.consumer.ConsumerImpl

ConsumerImpl.Option

Field Summary

Fields inherited from interface org.apache.qpid.server.consumer.ConsumerImpl

CONSUMER_NUMBER_GENERATOR

Constructor Summary

Constructors

Constructor and Description
Consumer(String consumerName, ConsumerTarget target)

Method Summary

Modifier and Type	Method and Description
boolean	acquires()
void	close()
void	externalStateChange()
void	flush()
long	getBytesOut()
long	getConsumerNumber()
MessageSource	getMessageSource()
long	getMessagesOut()
String	getName()
void	getSendLock()
AMQSessionModel	getSessionModel()
ConsumerTarget	getTarget()
long	getUnacknowledgedBytes()
long	getUnacknowledgedMessages()
boolean	isActive()
boolean	isClosed()
boolean	isSuspended()
void	releaseSendLock()
boolean	seesRequeues()
void	send(InternalMessage response)
boolean	trySendLock()

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer(String consumerName,
                ConsumerTarget target)

Method Detail

externalStateChange

public void externalStateChange()

Specified by:

externalStateChange in interface ConsumerImpl

getTarget

public ConsumerTarget getTarget()

Specified by:

getTarget in interface ConsumerImpl

getBytesOut

public long getBytesOut()

Specified by:

getBytesOut in interface ConsumerImpl

getMessagesOut

public long getMessagesOut()

Specified by:

getMessagesOut in interface ConsumerImpl

getUnacknowledgedBytes

public long getUnacknowledgedBytes()

Specified by:

getUnacknowledgedBytes in interface ConsumerImpl

getUnacknowledgedMessages

public long getUnacknowledgedMessages()

Specified by:

getUnacknowledgedMessages in interface ConsumerImpl

getSessionModel

public AMQSessionModel getSessionModel()

Specified by:

getSessionModel in interface ConsumerImpl

getMessageSource

public MessageSource getMessageSource()

Specified by:

getMessageSource in interface ConsumerImpl

getConsumerNumber

public long getConsumerNumber()

Specified by:

getConsumerNumber in interface ConsumerImpl

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface ConsumerImpl

isClosed

public boolean isClosed()

Specified by:

isClosed in interface ConsumerImpl

acquires

public boolean acquires()

Specified by:

acquires in interface ConsumerImpl

seesRequeues

public boolean seesRequeues()

Specified by:

seesRequeues in interface ConsumerImpl

close

public void close()

Specified by:

close in interface ConsumerImpl

trySendLock

public boolean trySendLock()

Specified by:

trySendLock in interface ConsumerImpl

getSendLock

public void getSendLock()

Specified by:

getSendLock in interface ConsumerImpl

releaseSendLock

public void releaseSendLock()

Specified by:

releaseSendLock in interface ConsumerImpl

isActive

public boolean isActive()

Specified by:

isActive in interface ConsumerImpl

getName

public String getName()

Specified by:

getName in interface ConsumerImpl

flush

public void flush()

Specified by:

flush in interface ConsumerImpl

send

public void send(InternalMessage response)