public interface ActiveMQServer extends ServiceComponent
This is not part of our public API.
| Modifier and Type | Interface and Description |
|---|---|
static class |
ActiveMQServer.SERVER_STATE |
| Modifier and Type | Method and Description |
|---|---|
void |
addActivationParam(String key,
Object val) |
boolean |
addAddressInfo(AddressInfo addressInfo)
Add the
AddressInfo to the broker |
boolean |
addClientConnection(String clientId,
boolean unique) |
void |
addExternalComponent(ActiveMQComponent externalComponent) |
AddressInfo |
addOrUpdateAddressInfo(AddressInfo addressInfo)
A convenience method to combine the functionality of
addAddressInfo and updateAddressInfo. |
void |
addProtocolManagerFactory(ProtocolManagerFactory factory) |
AddressQueryResult |
addressQuery(SimpleString name) |
void |
addScaledDownNode(SimpleString scaledDownNodeId) |
default BindingQueryResult |
bindingQuery(SimpleString address) |
BindingQueryResult |
bindingQuery(SimpleString address,
boolean newFQQN) |
void |
callActivationFailureListeners(Exception e)
Alert activation failure listeners of a failure.
|
void |
callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun) |
void |
callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun) |
void |
callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun) |
void |
callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun) |
void |
callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun) |
void |
callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun) |
void |
callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun) |
void |
callBrokerPlugins(ActiveMQPluginRunnable pluginRun) |
void |
callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun) |
void |
callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun) |
void |
callPostQueueCreationCallbacks(SimpleString queueName) |
void |
callPostQueueDeletionCallbacks(SimpleString address,
SimpleString queueName) |
void |
checkQueueCreationLimit(String username) |
void |
clearAddressCache() |
ActiveMQServer |
createBackupServer(Configuration configuration) |
PagingManager |
createPagingManager() |
Queue |
createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreateAddress) |
Queue |
createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString user,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
ServerSession |
createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
void |
createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Creates a transient queue.
|
void |
createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue) |
void |
createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteTimeout,
long autoDeleteMessageCount) |
void |
createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount) |
void |
deployBridge(BridgeConfiguration config) |
void |
deployDivert(DivertConfiguration config) |
void |
deployFederation(FederationConfiguration config) |
Queue |
deployQueue(SimpleString address,
SimpleString queue,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
Queue |
deployQueue(String address,
String queue,
String filter,
boolean durable,
boolean temporary)
Deprecated.
|
String |
describe() |
void |
destroyBridge(String name) |
String |
destroyConnectionWithSessionMetadata(String metaKey,
String metaValue) |
void |
destroyDivert(SimpleString name) |
void |
destroyQueue(SimpleString queueName) |
void |
destroyQueue(SimpleString queueName,
SecurityAuth session) |
void |
destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount) |
void |
destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers) |
void |
destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress) |
void |
destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress,
boolean checkMessageCount) |
void |
fail(boolean failoverOnServerShutdown) |
Activation |
getActivation() |
ActiveMQServerControlImpl |
getActiveMQServerControl()
Returns the resource to manage this ActiveMQ Artemis server.
|
AddressInfo |
getAddressInfo(SimpleString address) |
HierarchicalRepository<AddressSettings> |
getAddressSettingsRepository() |
List<ActiveMQServerAddressPlugin> |
getBrokerAddressPlugins() |
List<ActiveMQServerBindingPlugin> |
getBrokerBindingPlugins() |
List<ActiveMQServerBridgePlugin> |
getBrokerBridgePlugins() |
List<ActiveMQServerConnectionPlugin> |
getBrokerConnectionPlugins() |
List<ActiveMQServerConsumerPlugin> |
getBrokerConsumerPlugins() |
List<ActiveMQServerCriticalPlugin> |
getBrokerCriticalPlugins() |
List<ActiveMQServerMessagePlugin> |
getBrokerMessagePlugins() |
List<ActiveMQServerBasePlugin> |
getBrokerPlugins() |
List<ActiveMQServerQueuePlugin> |
getBrokerQueuePlugins() |
List<ActiveMQServerSessionPlugin> |
getBrokerSessionPlugins() |
ClusterManager |
getClusterManager() |
Configuration |
getConfiguration() |
int |
getConnectionCount() |
ConnectorsService |
getConnectorsService() |
CriticalAnalyzer |
getCriticalAnalyzer() |
ExecutorFactory |
getExecutorFactory() |
List<ActiveMQComponent> |
getExternalComponents() |
FederationManager |
getFederationManager() |
GroupingHandler |
getGroupingHandler() |
HAPolicy |
getHAPolicy() |
String |
getIdentity() |
String |
getInternalNamingPrefix() |
ExecutorFactory |
getIOExecutorFactory() |
ManagementService |
getManagementService() |
MetricsManager |
getMetricsManager() |
NetworkHealthCheck |
getNetworkHealthCheck() |
SimpleString |
getNodeID() |
NodeManager |
getNodeManager() |
PagingManager |
getPagingManager() |
PostOffice |
getPostOffice() |
QueueFactory |
getQueueFactory() |
ReloadManager |
getReloadManager() |
RemotingService |
getRemotingService() |
ReplicationEndpoint |
getReplicationEndpoint() |
ReplicationManager |
getReplicationManager() |
ResourceManager |
getResourceManager() |
ScheduledExecutorService |
getScheduledPool() |
ActiveMQSecurityManager |
getSecurityManager() |
HierarchicalRepository<Set<Role>> |
getSecurityRepository() |
SecurityStore |
getSecurityStore() |
ServiceRegistry |
getServiceRegistry() |
ServerSession |
getSessionByID(String sessionID) |
Set<ServerSession> |
getSessions() |
List<ServerSession> |
getSessions(String connectionID) |
ActiveMQServer.SERVER_STATE |
getState() |
StorageManager |
getStorageManager() |
Executor |
getThreadPool() |
long |
getTotalConnectionCount() |
long |
getTotalConsumerCount() |
long |
getTotalMessageCount() |
long |
getTotalMessagesAcknowledged() |
long |
getTotalMessagesAdded() |
String |
getUptime() |
long |
getUptimeMillis() |
Version |
getVersion() |
boolean |
hasBrokerAddressPlugins() |
boolean |
hasBrokerBindingPlugins() |
boolean |
hasBrokerBridgePlugins() |
boolean |
hasBrokerConnectionPlugins() |
boolean |
hasBrokerConsumerPlugins() |
boolean |
hasBrokerCriticalPlugins() |
boolean |
hasBrokerMessagePlugins() |
boolean |
hasBrokerPlugins() |
boolean |
hasBrokerQueuePlugins() |
boolean |
hasBrokerSessionPlugins() |
boolean |
hasScaledDown(SimpleString scaledDownNodeId) |
boolean |
isActive() |
boolean |
isAddressBound(String address)
return true if there is a binding for this address (i.e.
|
boolean |
isReplicaSync()
Returns whether the initial replication synchronization process with the backup server is complete; applicable for
either the live or backup server.
|
Queue |
locateQueue(SimpleString queueName) |
void |
lockActivation()
it will hold a lock for the activation.
|
ServerSession |
lookupSession(String metakey,
String metavalue) |
OperationContext |
newOperationContext() |
QueueQueryResult |
queueQuery(SimpleString name) |
void |
registerActivateCallback(ActivateCallback callback) |
void |
registerActivationFailureListener(ActivationFailureListener listener)
Register a listener to detect problems during activation
|
void |
registerBrokerPlugin(ActiveMQServerBasePlugin plugin) |
void |
registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins) |
void |
registerPostQueueCreationCallback(PostQueueCreationCallback callback) |
void |
registerPostQueueDeletionCallback(PostQueueDeletionCallback callback) |
void |
removeAddressInfo(SimpleString address,
SecurityAuth auth)
Remove an
AddressInfo from the broker. |
void |
removeAddressInfo(SimpleString address,
SecurityAuth auth,
boolean force)
Remove an
AddressInfo from the broker. |
void |
removeClientConnection(String clientId) |
void |
removeProtocolManagerFactory(ProtocolManagerFactory factory) |
void |
removeSession(String name) |
void |
setGroupingHandler(GroupingHandler groupingHandler) |
void |
setHAPolicy(HAPolicy haPolicy) |
void |
setIdentity(String identity)
Sets the server identity.
|
void |
setMBeanServer(MBeanServer mBeanServer) |
void |
setState(ActiveMQServer.SERVER_STATE state) |
void |
stop(boolean failoverOnServerShutdown,
boolean isExit) |
void |
threadDump() |
void |
undeployFederation(String name) |
void |
unlockActivation()
it will release hold a lock for the activation.
|
void |
unregisterActivateCallback(ActivateCallback callback) |
void |
unregisterActivationFailureListener(ActivationFailureListener listener)
Remove a previously registered failure listener
|
void |
unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin) |
void |
unregisterPostQueueCreationCallback(PostQueueCreationCallback callback) |
void |
unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback) |
boolean |
updateAddressInfo(SimpleString address,
Collection<RoutingType> routingTypes)
Deprecated.
|
boolean |
updateAddressInfo(SimpleString address,
EnumSet<RoutingType> routingTypes)
Updates an
AddressInfo on the broker with the specified routing types. |
Queue |
updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers) |
Queue |
updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Queue |
updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
String user) |
Queue |
updateQueue(String name,
RoutingType routingType,
String filterString,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
String user) |
Queue |
updateQueue(String name,
RoutingType routingType,
String filterString,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
String groupFirstQueue,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
String user) |
boolean |
waitForActivation(long timeout,
TimeUnit unit)
Wait for server initialization.
|
stopisStarted, start, stopvoid setState(ActiveMQServer.SERVER_STATE state)
ActiveMQServer.SERVER_STATE getState()
void setIdentity(String identity)
The identity will be exposed on logs. It may help to debug issues on the log traces and debugs.
This method was created mainly for testing but it may be used in scenarios where you need to have more than one Server inside the same VM.
String getIdentity()
String describe()
Configuration getConfiguration()
ServiceRegistry getServiceRegistry()
RemotingService getRemotingService()
StorageManager getStorageManager()
PagingManager getPagingManager()
PagingManager createPagingManager() throws Exception
ExceptionManagementService getManagementService()
ActiveMQSecurityManager getSecurityManager()
NetworkHealthCheck getNetworkHealthCheck()
Version getVersion()
NodeManager getNodeManager()
CriticalAnalyzer getCriticalAnalyzer()
ReplicationEndpoint getReplicationEndpoint()
void unlockActivation()
void lockActivation()
ActiveMQServerControlImpl getActiveMQServerControl()
IllegalStateException - if the server is not properly started.void registerActivateCallback(ActivateCallback callback)
void unregisterActivateCallback(ActivateCallback callback)
void registerActivationFailureListener(ActivationFailureListener listener)
listener - @see org.apache.activemq.artemis.core.server.ActivationFailureListenervoid unregisterActivationFailureListener(ActivationFailureListener listener)
listener - void callActivationFailureListeners(Exception e)
e - the exception that caused the activation failurevoid registerPostQueueCreationCallback(PostQueueCreationCallback callback)
callback - PostQueueCreationCallbackvoid unregisterPostQueueCreationCallback(PostQueueCreationCallback callback)
callback - PostQueueCreationCallbackvoid callPostQueueCreationCallbacks(SimpleString queueName) throws Exception
queueName - Exceptionvoid registerPostQueueDeletionCallback(PostQueueDeletionCallback callback)
callback - PostQueueDeletionCallbackvoid unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback)
callback - PostQueueDeletionCallbackvoid callPostQueueDeletionCallbacks(SimpleString address, SimpleString queueName) throws Exception
queueName - Exceptionvoid registerBrokerPlugin(ActiveMQServerBasePlugin plugin)
void unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin)
void registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins)
List<ActiveMQServerBasePlugin> getBrokerPlugins()
List<ActiveMQServerConnectionPlugin> getBrokerConnectionPlugins()
List<ActiveMQServerSessionPlugin> getBrokerSessionPlugins()
List<ActiveMQServerConsumerPlugin> getBrokerConsumerPlugins()
List<ActiveMQServerAddressPlugin> getBrokerAddressPlugins()
List<ActiveMQServerQueuePlugin> getBrokerQueuePlugins()
List<ActiveMQServerBindingPlugin> getBrokerBindingPlugins()
List<ActiveMQServerMessagePlugin> getBrokerMessagePlugins()
List<ActiveMQServerBridgePlugin> getBrokerBridgePlugins()
List<ActiveMQServerCriticalPlugin> getBrokerCriticalPlugins()
void callBrokerPlugins(ActiveMQPluginRunnable pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionvoid callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun) throws ActiveMQException
ActiveMQExceptionboolean hasBrokerPlugins()
boolean hasBrokerConnectionPlugins()
boolean hasBrokerSessionPlugins()
boolean hasBrokerConsumerPlugins()
boolean hasBrokerAddressPlugins()
boolean hasBrokerQueuePlugins()
boolean hasBrokerBindingPlugins()
boolean hasBrokerMessagePlugins()
boolean hasBrokerBridgePlugins()
boolean hasBrokerCriticalPlugins()
void checkQueueCreationLimit(String username) throws Exception
ExceptionServerSession createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes) throws Exception
ExceptionSecurityStore getSecurityStore()
Set<ServerSession> getSessions()
HierarchicalRepository<Set<Role>> getSecurityRepository()
HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
OperationContext newOperationContext()
int getConnectionCount()
long getTotalConnectionCount()
long getTotalMessageCount()
long getTotalMessagesAdded()
long getTotalMessagesAcknowledged()
long getTotalConsumerCount()
PostOffice getPostOffice()
void clearAddressCache()
QueueFactory getQueueFactory()
ResourceManager getResourceManager()
MetricsManager getMetricsManager()
List<ServerSession> getSessions(String connectionID)
ServerSession lookupSession(String metakey, String metavalue)
ClusterManager getClusterManager()
SimpleString getNodeID()
boolean isActive()
String getUptime()
long getUptimeMillis()
boolean isReplicaSync()
boolean waitForActivation(long timeout,
TimeUnit unit)
throws InterruptedException
timeout - unit - true if the server was already initialized or if it was initialized within the
timeout period, false otherwise.InterruptedExceptionCountDownLatch.await(long, java.util.concurrent.TimeUnit)void createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable) throws Exception
Notice: the queue won't be deleted until the first consumer arrives.
address - name - filterString - durable - ActiveMQInvalidTransientQueueUseException - if the shared queue already exists with a different address or filterStringNullPointerException - if address is nullExceptionvoid createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue) throws Exception
Exceptionvoid createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteTimeout, long autoDeleteMessageCount) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
ExceptionQueue createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) throws Exception
Exception@Deprecated Queue createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) throws Exception
Exception@Deprecated Queue deployQueue(String address, String queue, String filter, boolean durable, boolean temporary) throws Exception
Exception@Deprecated Queue deployQueue(SimpleString address, SimpleString queue, SimpleString filter, boolean durable, boolean temporary) throws Exception
Exceptionvoid createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount) throws Exception
ExceptionQueue locateQueue(SimpleString queueName)
default BindingQueryResult bindingQuery(SimpleString address) throws Exception
ExceptionBindingQueryResult bindingQuery(SimpleString address, boolean newFQQN) throws Exception
ExceptionQueueQueryResult queueQuery(SimpleString name) throws Exception
ExceptionAddressQueryResult addressQuery(SimpleString name) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName, SecurityAuth session) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) throws Exception
Exceptionvoid destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress, boolean checkMessageCount) throws Exception
ExceptionString destroyConnectionWithSessionMetadata(String metaKey, String metaValue) throws Exception
ExceptionScheduledExecutorService getScheduledPool()
ExecutorFactory getExecutorFactory()
ExecutorFactory getIOExecutorFactory()
void setGroupingHandler(GroupingHandler groupingHandler)
GroupingHandler getGroupingHandler()
ReplicationManager getReplicationManager()
FederationManager getFederationManager()
void deployDivert(DivertConfiguration config) throws Exception
Exceptionvoid destroyDivert(SimpleString name) throws Exception
ExceptionConnectorsService getConnectorsService()
void deployBridge(BridgeConfiguration config) throws Exception
Exceptionvoid deployFederation(FederationConfiguration config) throws Exception
ExceptionServerSession getSessionByID(String sessionID)
void threadDump()
boolean isAddressBound(String address) throws Exception
address - ExceptionQueue updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers) throws Exception
ExceptionQueue updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive) throws Exception
ExceptionQueue updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user) throws Exception
ExceptionQueue updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user) throws Exception
ExceptionQueue updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstQueue, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user) throws Exception
Exceptionvoid addProtocolManagerFactory(ProtocolManagerFactory factory)
void removeProtocolManagerFactory(ProtocolManagerFactory factory)
ReloadManager getReloadManager()
ActiveMQServer createBackupServer(Configuration configuration)
void addScaledDownNode(SimpleString scaledDownNodeId)
boolean hasScaledDown(SimpleString scaledDownNodeId)
Activation getActivation()
HAPolicy getHAPolicy()
void setHAPolicy(HAPolicy haPolicy)
void setMBeanServer(MBeanServer mBeanServer)
void addExternalComponent(ActiveMQComponent externalComponent)
List<ActiveMQComponent> getExternalComponents()
boolean addClientConnection(String clientId, boolean unique)
void removeClientConnection(String clientId)
Executor getThreadPool()
AddressInfo getAddressInfo(SimpleString address)
boolean updateAddressInfo(SimpleString address, EnumSet<RoutingType> routingTypes) throws Exception
AddressInfo on the broker with the specified routing types.address - the name of the AddressInfo to updateroutingTypes - the routing types to update the AddressInfo withtrue if the AddressInfo was updated, false otherwiseException@Deprecated boolean updateAddressInfo(SimpleString address, Collection<RoutingType> routingTypes) throws Exception
Exceptionboolean addAddressInfo(AddressInfo addressInfo) throws Exception
AddressInfo to the brokeraddressInfo - the AddressInfo to addtrue if the AddressInfo was added, false otherwiseExceptionAddressInfo addOrUpdateAddressInfo(AddressInfo addressInfo) throws Exception
addAddressInfo and updateAddressInfo. It will
add the AddressInfo object to the broker if it doesn't exist or update it if it does.addressInfo - the AddressInfo to add or the info used to update the existing AddressInfoAddressInfoExceptionvoid removeAddressInfo(SimpleString address, SecurityAuth auth) throws Exception
AddressInfo from the broker.address - the AddressInfo to removeauth - authorization information; null is validExceptionvoid removeAddressInfo(SimpleString address, SecurityAuth auth, boolean force) throws Exception
AddressInfo from the broker.address - the AddressInfo to removeauth - authorization information; null is validforce - It will disconnect everything from the address including queues and consumersExceptionString getInternalNamingPrefix()
Copyright © 2019 JBoss by Red Hat. All rights reserved.