Modifier and Type | Method and Description |
---|---|
void |
StorageManager.addQueueBinding(long tx,
Binding binding) |
void |
StorageManager.updateQueueBinding(long tx,
Binding binding) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournalStorageManager.addQueueBinding(long tx,
Binding binding) |
void |
AbstractJournalStorageManager.updateQueueBinding(long tx,
Binding binding) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.addQueueBinding(long tx,
Binding binding) |
void |
NullStorageManager.updateQueueBinding(long tx,
Binding binding) |
Modifier and Type | Interface and Description |
---|---|
interface |
QueueBinding |
Modifier and Type | Method and Description |
---|---|
Binding |
PostOffice.getBinding(SimpleString uniqueName) |
Binding |
AddressManager.getBinding(SimpleString queueName) |
Binding |
AddressManager.removeBinding(SimpleString uniqueName,
Transaction tx)
This will use a Transaction as we need to confirm the queue was removed
|
Binding |
PostOffice.removeBinding(SimpleString uniqueName,
Transaction tx,
boolean deleteData) |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,Binding> |
PostOffice.getAllBindings() |
Collection<Binding> |
Bindings.getBindings() |
Map<SimpleString,Binding> |
AddressManager.getBindings() |
Modifier and Type | Method and Description |
---|---|
void |
PostOffice.addBinding(Binding binding) |
void |
Bindings.addBinding(Binding binding) |
boolean |
AddressManager.addBinding(Binding binding) |
void |
Bindings.removeBinding(Binding binding) |
RoutingStatus |
PostOffice.route(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Binding binding) |
RoutingStatus |
PostOffice.route(Message message,
Transaction tx,
boolean direct,
boolean rejectDuplicates,
Binding binding) |
Modifier and Type | Class and Description |
---|---|
class |
DivertBinding |
class |
LocalQueueBinding |
Modifier and Type | Method and Description |
---|---|
Binding |
SimpleAddressManager.getBinding(SimpleString bindableName) |
Binding |
PostOfficeImpl.getBinding(SimpleString name) |
Binding |
WildcardAddressManager.removeBinding(SimpleString uniqueName,
Transaction tx)
If the address is a wild card then the binding will be removed from the actual mappings for any linked address.
|
Binding |
SimpleAddressManager.removeBinding(SimpleString uniqueName,
Transaction tx) |
Binding |
PostOfficeImpl.removeBinding(SimpleString uniqueName,
Transaction tx,
boolean deleteData) |
protected Binding |
SimpleAddressManager.removeMapping(SimpleString bindableName,
Bindings bindings) |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,Binding> |
PostOfficeImpl.getAllBindings() |
Map<SimpleString,Binding> |
SimpleAddressManager.getBindings() |
Collection<Binding> |
BindingsImpl.getBindings() |
Map<SimpleString,List<Binding>> |
BindingsImpl.getRoutingNameBindingMap() |
Modifier and Type | Method and Description |
---|---|
boolean |
WildcardAddressManager.addBinding(Binding binding)
If the address to add the binding to contains a wildcard then a copy of the binding (with the same underlying queue)
will be added to the actual mappings.
|
boolean |
SimpleAddressManager.addBinding(Binding binding) |
void |
PostOfficeImpl.addBinding(Binding binding) |
void |
BindingsImpl.addBinding(Binding binding) |
protected boolean |
SimpleAddressManager.addMappingInternal(SimpleString address,
Binding binding) |
void |
BindingsImpl.removeBinding(Binding binding) |
RoutingStatus |
PostOfficeImpl.route(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Binding bindingMove) |
RoutingStatus |
PostOfficeImpl.route(Message message,
Transaction tx,
boolean direct,
boolean rejectDuplicates,
Binding binding) |
Modifier and Type | Method and Description |
---|---|
ActiveMQQueueExistsException |
ActiveMQMessageBundle.bindingAlreadyExists(Binding binding) |
boolean |
Queue.moveReference(long messageID,
SimpleString toAddress,
Binding binding,
boolean rejectDuplicates) |
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress,
Binding binding) |
int |
Queue.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates,
Binding binding) |
Modifier and Type | Interface and Description |
---|---|
interface |
RemoteQueueBinding |
Modifier and Type | Class and Description |
---|---|
class |
RemoteQueueBindingImpl |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueImpl.moveReference(long messageID,
SimpleString toAddress,
Binding binding,
boolean rejectDuplicate) |
int |
QueueImpl.moveReferences(Filter filter,
SimpleString toAddress,
Binding binding) |
int |
QueueImpl.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates,
Binding binding) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerPlugin.afterAddBinding(Binding binding)
After a binding has been added
|
default void |
ActiveMQServerPlugin.afterRemoveBinding(Binding binding,
Transaction tx,
boolean deleteData)
After a binding is removed
|
default void |
ActiveMQServerPlugin.beforeAddBinding(Binding binding)
Before a binding is added
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.