org.apache.qpid.server.virtualhost

Class AbstractSystemMessageSource

java.lang.Object

org.apache.qpid.server.virtualhost.AbstractSystemMessageSource

All Implemented Interfaces:

MessageNode, MessageSource, TransactionLogResource

Direct Known Subclasses:

TrustStoreMessageSource, VirtualHostPropertiesNode

public abstract class AbstractSystemMessageSource
extends Object
implements MessageSource

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractSystemMessageSource.Consumer

Nested classes/interfaces inherited from interface org.apache.qpid.server.message.MessageSource

MessageSource.ConsumerAccessRefused, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ExistingExclusiveConsumer

Field Summary

Fields

Modifier and Type	Field and Description
protected UUID	_id
protected String	_name
protected VirtualHost<?,?,?>	_virtualHost

Constructor Summary

Constructors

Constructor and Description
AbstractSystemMessageSource(String name, VirtualHost<?,?,?> virtualHost)

Method Summary

Modifier and Type	Method and Description
AbstractSystemMessageSource.Consumer	addConsumer(ConsumerTarget target, FilterManager filters, Class<? extends ServerMessage> messageClass, String consumerName, EnumSet<ConsumerImpl.Option> options)
Collection<AbstractSystemMessageSource.Consumer>	getConsumers()
UUID	getId()
MessageDurability	getMessageDurability()
String	getName()
boolean	verifySessionAccess(AMQSessionModel<?> session)

Methods inherited from class java.lang.Object

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

Field Detail

_id

protected final UUID _id

_name

protected final String _name

_virtualHost

protected final VirtualHost<?,?,?> _virtualHost

Constructor Detail

AbstractSystemMessageSource

public AbstractSystemMessageSource(String name,
                                   VirtualHost<?,?,?> virtualHost)

Method Detail

getName

public String getName()

Specified by:

getName in interface MessageNode

Specified by:

getName in interface TransactionLogResource

getId

public UUID getId()

Specified by:

getId in interface TransactionLogResource

getMessageDurability

public MessageDurability getMessageDurability()

Specified by:

getMessageDurability in interface TransactionLogResource

addConsumer

public AbstractSystemMessageSource.Consumer addConsumer(ConsumerTarget target,
                                                        FilterManager filters,
                                                        Class<? extends ServerMessage> messageClass,
                                                        String consumerName,
                                                        EnumSet<ConsumerImpl.Option> options)
                                                 throws MessageSource.ExistingExclusiveConsumer,
                                                        MessageSource.ExistingConsumerPreventsExclusive,
                                                        MessageSource.ConsumerAccessRefused

Specified by:

addConsumer in interface MessageSource

Throws:

MessageSource.ExistingExclusiveConsumer

MessageSource.ExistingConsumerPreventsExclusive

MessageSource.ConsumerAccessRefused

getConsumers

public Collection<AbstractSystemMessageSource.Consumer> getConsumers()

Specified by:

getConsumers in interface MessageSource

verifySessionAccess

public boolean verifySessionAccess(AMQSessionModel<?> session)

Specified by:

verifySessionAccess in interface MessageSource