public interface MessageSource extends TransactionLogResource, MessageNode
Modifier and Type | Interface and Description |
---|---|
static class |
MessageSource.ConsumerAccessRefused |
static class |
MessageSource.ExistingConsumerPreventsExclusive
ExistingConsumerPreventsExclusive signals a failure to create an exclusive consumer, as a consumer
already exists.
|
static class |
MessageSource.ExistingExclusiveConsumer
ExistingExclusiveConsumer signals a failure to create a consumer, because an exclusive consumer
already exists.
|
Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
Collection<? extends ConsumerImpl> |
getConsumers() |
boolean |
verifySessionAccess(AMQSessionModel<?> session) |
getId, getMessageDurability, getName
getName
ConsumerImpl addConsumer(ConsumerTarget target, FilterManager filters, Class<? extends ServerMessage> messageClass, String consumerName, EnumSet<ConsumerImpl.Option> options) throws MessageSource.ExistingExclusiveConsumer, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ConsumerAccessRefused
Collection<? extends ConsumerImpl> getConsumers()
boolean verifySessionAccess(AMQSessionModel<?> session)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.