public abstract class AbstractSystemMessageSource extends Object implements MessageSource
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractSystemMessageSource.Consumer |
MessageSource.ConsumerAccessRefused, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ExistingExclusiveConsumer
Modifier and Type | Field and Description |
---|---|
protected UUID |
_id |
protected String |
_name |
protected VirtualHost<?,?,?> |
_virtualHost |
Constructor and Description |
---|
AbstractSystemMessageSource(String name,
VirtualHost<?,?,?> virtualHost) |
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) |
protected final UUID _id
protected final String _name
protected final VirtualHost<?,?,?> _virtualHost
public AbstractSystemMessageSource(String name, VirtualHost<?,?,?> virtualHost)
public String getName()
getName
in interface MessageNode
getName
in interface TransactionLogResource
public UUID getId()
getId
in interface TransactionLogResource
public MessageDurability getMessageDurability()
getMessageDurability
in interface TransactionLogResource
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
addConsumer
in interface MessageSource
MessageSource.ExistingExclusiveConsumer
MessageSource.ExistingConsumerPreventsExclusive
MessageSource.ConsumerAccessRefused
public Collection<AbstractSystemMessageSource.Consumer> getConsumers()
getConsumers
in interface MessageSource
public boolean verifySessionAccess(AMQSessionModel<?> session)
verifySessionAccess
in interface MessageSource
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.