|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.server.queue.SimpleAMQQueue
public class SimpleAMQQueue
Nested Class Summary | |
---|---|
static interface |
SimpleAMQQueue.QueueEntryFilter
|
Nested classes/interfaces inherited from interface org.apache.qpid.server.queue.AMQQueue |
---|
AMQQueue.Context, AMQQueue.ExistingExclusiveSubscription, AMQQueue.ExistingSubscriptionPreventsExclusive, AMQQueue.Task |
Nested classes/interfaces inherited from interface org.apache.qpid.server.queue.BaseQueue |
---|
BaseQueue.PostEnqueueAction |
Field Summary | |
---|---|
protected QueueEntryList |
_entries
Used to track bindings to exchanges so that on deletion they can easily be cancelled. |
long |
_maximumMessageAge
maximum message age before alerts occur |
long |
_maximumMessageCount
max allowed number of messages on a queue. |
long |
_maximumMessageSize
max allowed size(KB) of a single message |
long |
_maximumQueueDepth
max queue depth for the queue |
long |
_minimumAlertRepeatGap
the minimum interval between sending out consecutive alerts of the same type |
protected SubscriptionList |
_subscriptionList
|
(package private) static int |
MAX_ASYNC_DELIVERIES
|
Constructor Summary | |
---|---|
protected |
SimpleAMQQueue(org.apache.qpid.framing.AMQShortString name,
boolean durable,
org.apache.qpid.framing.AMQShortString owner,
boolean autoDelete,
boolean exclusive,
VirtualHost virtualHost,
Map<String,Object> arguments)
|
protected |
SimpleAMQQueue(org.apache.qpid.framing.AMQShortString name,
boolean durable,
org.apache.qpid.framing.AMQShortString owner,
boolean autoDelete,
boolean exclusive,
VirtualHost virtualHost,
QueueEntryListFactory entryListFactory,
Map<String,Object> arguments)
|
|
SimpleAMQQueue(String queueName,
boolean durable,
String owner,
boolean autoDelete,
boolean exclusive,
VirtualHost virtualHost,
Map<String,Object> arguments)
|
|
SimpleAMQQueue(String queueName,
boolean durable,
String owner,
boolean autoDelete,
boolean exclusive,
VirtualHost virtualHost,
QueueEntryListFactory entryListFactory,
Map<String,Object> arguments)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected final QueueEntryList _entries
protected final SubscriptionList _subscriptionList
public long _maximumMessageSize
public long _maximumMessageCount
public long _maximumQueueDepth
public long _maximumMessageAge
public long _minimumAlertRepeatGap
static final int MAX_ASYNC_DELIVERIES
Constructor Detail |
---|
protected SimpleAMQQueue(org.apache.qpid.framing.AMQShortString name, boolean durable, org.apache.qpid.framing.AMQShortString owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, Map<String,Object> arguments)
public SimpleAMQQueue(String queueName, boolean durable, String owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, Map<String,Object> arguments)
public SimpleAMQQueue(String queueName, boolean durable, String owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, QueueEntryListFactory entryListFactory, Map<String,Object> arguments)
protected SimpleAMQQueue(org.apache.qpid.framing.AMQShortString name, boolean durable, org.apache.qpid.framing.AMQShortString owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, QueueEntryListFactory entryListFactory, Map<String,Object> arguments)
Method Detail |
---|
public void resetNotifications()
public void execute(org.apache.qpid.pool.ReadWriteRunnable runnable)
public org.apache.qpid.framing.AMQShortString getNameShortString()
getNameShortString
in interface BaseQueue
public void setNoLocal(boolean nolocal)
setNoLocal
in interface AMQQueue
public UUID getId()
getId
in interface ConfiguredObject<QueueConfigType,QueueConfig>
public QueueConfigType getConfigType()
getConfigType
in interface ConfiguredObject<QueueConfigType,QueueConfig>
public ConfiguredObject getParent()
getParent
in interface ConfiguredObject<QueueConfigType,QueueConfig>
public boolean isDurable()
isDurable
in interface ConfiguredObject<QueueConfigType,QueueConfig>
isDurable
in interface BaseQueue
public boolean isExclusive()
isExclusive
in interface QueueConfig
isExclusive
in interface AMQQueue
public void setExclusive(boolean exclusive) throws org.apache.qpid.AMQException
setExclusive
in interface AMQQueue
org.apache.qpid.AMQException
public Exchange getAlternateExchange()
getAlternateExchange
in interface QueueConfig
getAlternateExchange
in interface AMQQueue
public void setAlternateExchange(Exchange exchange)
setAlternateExchange
in interface AMQQueue
public Map<String,Object> getArguments()
getArguments
in interface QueueConfig
getArguments
in interface AMQQueue
public boolean isAutoDelete()
isAutoDelete
in interface QueueConfig
isAutoDelete
in interface AMQQueue
public org.apache.qpid.framing.AMQShortString getOwner()
getOwner
in interface AMQQueue
public PrincipalHolder getPrincipalHolder()
getPrincipalHolder
in interface AMQQueue
public void setPrincipalHolder(PrincipalHolder prinicpalHolder)
setPrincipalHolder
in interface AMQQueue
public VirtualHost getVirtualHost()
getVirtualHost
in interface QueueConfig
getVirtualHost
in interface AMQQueue
public String getName()
getName
in interface QueueConfig
public void registerSubscription(Subscription subscription, boolean exclusive) throws org.apache.qpid.AMQSecurityException, AMQQueue.ExistingExclusiveSubscription, AMQQueue.ExistingSubscriptionPreventsExclusive
registerSubscription
in interface AMQQueue
org.apache.qpid.AMQSecurityException
AMQQueue.ExistingExclusiveSubscription
AMQQueue.ExistingSubscriptionPreventsExclusive
public void unregisterSubscription(Subscription subscription) throws org.apache.qpid.AMQException
unregisterSubscription
in interface AMQQueue
org.apache.qpid.AMQException
public boolean getDeleteOnNoConsumers()
getDeleteOnNoConsumers
in interface AMQQueue
public void setDeleteOnNoConsumers(boolean b)
setDeleteOnNoConsumers
in interface AMQQueue
public void addBinding(Binding binding)
addBinding
in interface AMQQueue
public int getBindingCountHigh()
getBindingCountHigh
in interface QueueConfig
public void removeBinding(Binding binding)
removeBinding
in interface AMQQueue
public List<Binding> getBindings()
getBindings
in interface AMQQueue
public int getBindingCount()
getBindingCount
in interface QueueConfig
getBindingCount
in interface AMQQueue
public LogSubject getLogSubject()
getLogSubject
in interface AMQQueue
public void enqueue(ServerMessage message) throws org.apache.qpid.AMQException
enqueue
in interface BaseQueue
org.apache.qpid.AMQException
public void enqueue(ServerMessage message, BaseQueue.PostEnqueueAction action) throws org.apache.qpid.AMQException
enqueue
in interface BaseQueue
org.apache.qpid.AMQException
protected void checkSubscriptionsNotAheadOfDelivery(QueueEntry entry)
public void requeue(QueueEntry entry)
requeue
in interface AMQQueue
public void requeue(QueueEntryImpl entry, Subscription subscription)
requeue
in interface AMQQueue
public void dequeue(QueueEntry entry, Subscription sub)
dequeue
in interface AMQQueue
void decrementQueueCount()
public boolean resend(QueueEntry entry, Subscription subscription) throws org.apache.qpid.AMQException
resend
in interface AMQQueue
org.apache.qpid.AMQException
public int getConsumerCount()
getConsumerCount
in interface QueueConfig
getConsumerCount
in interface AMQQueue
public int getConsumerCountHigh()
getConsumerCountHigh
in interface QueueConfig
public int getActiveConsumerCount()
getActiveConsumerCount
in interface AMQQueue
public boolean isUnused()
isUnused
in interface AMQQueue
public boolean isEmpty()
isEmpty
in interface AMQQueue
public int getMessageCount()
getMessageCount
in interface QueueConfig
getMessageCount
in interface AMQQueue
public long getQueueDepth()
getQueueDepth
in interface QueueConfig
getQueueDepth
in interface AMQQueue
public int getUndeliveredMessageCount()
getUndeliveredMessageCount
in interface AMQQueue
public long getReceivedMessageCount()
getReceivedMessageCount
in interface QueueConfig
getReceivedMessageCount
in interface AMQQueue
public long getOldestMessageArrivalTime()
getOldestMessageArrivalTime
in interface AMQQueue
protected QueueEntry getOldestQueueEntry()
public boolean isDeleted()
isDeleted
in interface AMQQueue
public List<QueueEntry> getMessagesOnTheQueue()
getMessagesOnTheQueue
in interface AMQQueue
public void stateChange(Subscription sub, Subscription.State oldState, Subscription.State newState)
stateChange
in interface Subscription.StateListener
public int compareTo(AMQQueue o)
compareTo
in interface Comparable<AMQQueue>
public AtomicInteger getAtomicQueueCount()
public AtomicLong getAtomicQueueSize()
public boolean hasExclusiveSubscriber()
hasExclusiveSubscriber
in interface AMQQueue
public List<QueueEntry> getMessagesOnTheQueue(long fromMessageId, long toMessageId)
getMessagesOnTheQueue
in interface AMQQueue
public QueueEntry getMessageOnTheQueue(long messageId)
getMessageOnTheQueue
in interface AMQQueue
public List<QueueEntry> getMessagesOnTheQueue(SimpleAMQQueue.QueueEntryFilter filter)
public List<QueueEntry> getMessagesRangeOnTheQueue(long fromPosition, long toPosition)
getMessagesRangeOnTheQueue
in interface AMQQueue
fromPosition
- toPosition
-
public void moveMessagesToAnotherQueue(long fromMessageId, long toMessageId, String queueName, ServerTransaction txn) throws IllegalArgumentException
moveMessagesToAnotherQueue
in interface AMQQueue
IllegalArgumentException
public void copyMessagesToAnotherQueue(long fromMessageId, long toMessageId, String queueName, ServerTransaction txn) throws IllegalArgumentException
copyMessagesToAnotherQueue
in interface AMQQueue
IllegalArgumentException
public void removeMessagesFromQueue(long fromMessageId, long toMessageId)
removeMessagesFromQueue
in interface AMQQueue
public void purge(long request) throws org.apache.qpid.AMQException
purge
in interface QueueConfig
org.apache.qpid.AMQException
public long getCreateTime()
getCreateTime
in interface ConfiguredObject<QueueConfigType,QueueConfig>
public void deleteMessageFromTop()
deleteMessageFromTop
in interface AMQQueue
public long clearQueue() throws org.apache.qpid.AMQException
clearQueue
in interface AMQQueue
org.apache.qpid.AMQException
public void addQueueDeleteTask(AMQQueue.Task task)
addQueueDeleteTask
in interface AMQQueue
public void removeQueueDeleteTask(AMQQueue.Task task)
removeQueueDeleteTask
in interface AMQQueue
public int delete() throws org.apache.qpid.AMQSecurityException, org.apache.qpid.AMQException
delete
in interface AMQQueue
org.apache.qpid.AMQSecurityException
org.apache.qpid.AMQException
public void stop()
stop
in interface AMQQueue
public void checkCapacity(AMQChannel channel)
checkCapacity
in interface AMQQueue
public void deliverAsync()
deliverAsync
in interface AMQQueue
public void deliverAsync(Subscription sub)
deliverAsync
in interface AMQQueue
public void flushSubscription(Subscription sub) throws org.apache.qpid.AMQException
flushSubscription
in interface AMQQueue
org.apache.qpid.AMQException
public boolean flushSubscription(Subscription sub, long iterations) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
protected void advanceAllSubscriptions() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void checkMessageStatus() throws org.apache.qpid.AMQException
AMQQueue
checkMessageStatus
in interface AMQQueue
org.apache.qpid.AMQException
public long getMinimumAlertRepeatGap()
getMinimumAlertRepeatGap
in interface AMQQueue
public void setMinimumAlertRepeatGap(long minimumAlertRepeatGap)
setMinimumAlertRepeatGap
in interface AMQQueue
public long getMaximumMessageAge()
getMaximumMessageAge
in interface AMQQueue
public void setMaximumMessageAge(long maximumMessageAge)
setMaximumMessageAge
in interface AMQQueue
public long getMaximumMessageCount()
getMaximumMessageCount
in interface AMQQueue
public void setMaximumMessageCount(long maximumMessageCount)
setMaximumMessageCount
in interface AMQQueue
public long getMaximumQueueDepth()
getMaximumQueueDepth
in interface AMQQueue
public void setMaximumQueueDepth(long maximumQueueDepth)
setMaximumQueueDepth
in interface AMQQueue
public long getMaximumMessageSize()
getMaximumMessageSize
in interface AMQQueue
public void setMaximumMessageSize(long maximumMessageSize)
setMaximumMessageSize
in interface AMQQueue
public long getCapacity()
getCapacity
in interface AMQQueue
public void setCapacity(long capacity)
setCapacity
in interface AMQQueue
public long getFlowResumeCapacity()
getFlowResumeCapacity
in interface AMQQueue
public void setFlowResumeCapacity(long flowResumeCapacity)
setFlowResumeCapacity
in interface AMQQueue
public boolean isOverfull()
isOverfull
in interface AMQQueue
public Set<NotificationCheck> getNotificationChecks()
getNotificationChecks
in interface AMQQueue
public ManagedObject getManagedObject()
getManagedObject
in interface Managable
getManagedObject
in interface AMQQueue
public List<Long> getMessagesOnTheQueue(int num)
getMessagesOnTheQueue
in interface AMQQueue
public List<Long> getMessagesOnTheQueue(int num, int offset)
getMessagesOnTheQueue
in interface AMQQueue
public AMQSessionModel getExclusiveOwningSession()
getExclusiveOwningSession
in interface AMQQueue
public void setExclusiveOwningSession(AMQSessionModel exclusiveOwner)
setExclusiveOwningSession
in interface AMQQueue
public void configure(ConfigurationPlugin config)
configure
in interface AMQQueue
public ConfigurationPlugin getConfiguration()
getConfiguration
in interface AMQQueue
public String getResourceName()
getResourceName
in interface TransactionLogResource
public ConfigStore getConfigStore()
getConfigStore
in interface QueueConfig
public long getMessageDequeueCount()
getMessageDequeueCount
in interface QueueConfig
public long getTotalEnqueueSize()
getTotalEnqueueSize
in interface QueueConfig
public long getTotalDequeueSize()
getTotalDequeueSize
in interface QueueConfig
public long getByteTxnEnqueues()
getByteTxnEnqueues
in interface QueueConfig
public long getByteTxnDequeues()
getByteTxnDequeues
in interface QueueConfig
public long getMsgTxnEnqueues()
getMsgTxnEnqueues
in interface QueueConfig
public long getMsgTxnDequeues()
getMsgTxnDequeues
in interface QueueConfig
public long getPersistentByteEnqueues()
getPersistentByteEnqueues
in interface QueueConfig
public long getPersistentByteDequeues()
getPersistentByteDequeues
in interface QueueConfig
public long getPersistentMsgEnqueues()
getPersistentMsgEnqueues
in interface QueueConfig
public long getPersistentMsgDequeues()
getPersistentMsgDequeues
in interface QueueConfig
public String toString()
toString
in class Object
public long getUnackedMessageCountHigh()
getUnackedMessageCountHigh
in interface QueueConfig
public long getUnackedMessageCount()
getUnackedMessageCount
in interface QueueConfig
public void decrementUnackedMsgCount()
decrementUnackedMsgCount
in interface AMQQueue
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |