protected class AbstractSystemMessageSource.Consumer extends Object implements ConsumerImpl
ConsumerImpl.Option
CONSUMER_NUMBER_GENERATOR
Constructor and Description |
---|
Consumer(String consumerName,
ConsumerTarget target) |
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() |
public Consumer(String consumerName, ConsumerTarget target)
public void externalStateChange()
externalStateChange
in interface ConsumerImpl
public ConsumerTarget getTarget()
getTarget
in interface ConsumerImpl
public long getBytesOut()
getBytesOut
in interface ConsumerImpl
public long getMessagesOut()
getMessagesOut
in interface ConsumerImpl
public long getUnacknowledgedBytes()
getUnacknowledgedBytes
in interface ConsumerImpl
public long getUnacknowledgedMessages()
getUnacknowledgedMessages
in interface ConsumerImpl
public AMQSessionModel getSessionModel()
getSessionModel
in interface ConsumerImpl
public MessageSource getMessageSource()
getMessageSource
in interface ConsumerImpl
public long getConsumerNumber()
getConsumerNumber
in interface ConsumerImpl
public boolean isSuspended()
isSuspended
in interface ConsumerImpl
public boolean isClosed()
isClosed
in interface ConsumerImpl
public boolean acquires()
acquires
in interface ConsumerImpl
public boolean seesRequeues()
seesRequeues
in interface ConsumerImpl
public void close()
close
in interface ConsumerImpl
public boolean trySendLock()
trySendLock
in interface ConsumerImpl
public void getSendLock()
getSendLock
in interface ConsumerImpl
public void releaseSendLock()
releaseSendLock
in interface ConsumerImpl
public boolean isActive()
isActive
in interface ConsumerImpl
public String getName()
getName
in interface ConsumerImpl
public void flush()
flush
in interface ConsumerImpl
public void send(InternalMessage response)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.