public interface HornetQServer extends HornetQComponent
This is not part of our public API.
isStarted, start, stop
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()
RemotingService getRemotingService()
StorageManager getStorageManager()
PagingManager getPagingManager()
ManagementService getManagementService()
HornetQSecurityManager getSecurityManager()
Version getVersion()
NodeManager getNodeManager()
HornetQServerControlImpl getHornetQServerControl()
IllegalStateException
- if the server is not properly started.void registerActivateCallback(ActivateCallback callback)
void unregisterActivateCallback(ActivateCallback callback)
ServerSession createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback) throws Exception
Exception
Set<ServerSession> getSessions()
HierarchicalRepository<Set<Role>> getSecurityRepository()
HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
int getConnectionCount()
PostOffice getPostOffice()
QueueFactory getQueueFactory()
ResourceManager getResourceManager()
List<ServerSession> getSessions(String connectionID)
ServerSession lookupSession(String metakey, String metavalue)
ClusterManager getClusterManager()
SimpleString getNodeID()
boolean isActive()
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.InterruptedException
CountDownLatch#await(long, TimeUnit)
boolean waitForBackupSync(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.InterruptedException
CountDownLatch#await(long, TimeUnit)
void createSharedQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean durable) throws Exception
address
- name
- filterString
- durable
- Exception
Queue createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) throws Exception
Exception
Queue deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) throws Exception
Exception
Queue locateQueue(SimpleString queueName) throws Exception
Exception
void destroyQueue(SimpleString queueName) throws Exception
Exception
void destroyQueue(SimpleString queueName, ServerSession session) throws Exception
Exception
void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount) throws Exception
Exception
void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount, boolean removeConsumers) throws Exception
Exception
String destroyConnectionWithSessionMetadata(String metaKey, String metaValue) throws Exception
Exception
ScheduledExecutorService getScheduledPool()
ExecutorFactory getExecutorFactory()
void setGroupingHandler(GroupingHandler groupingHandler)
GroupingHandler getGroupingHandler()
ReplicationEndpoint getReplicationEndpoint()
ReplicationManager getReplicationManager()
void deployDivert(DivertConfiguration config) throws Exception
Exception
void destroyDivert(SimpleString name) throws Exception
Exception
ConnectorsService getConnectorsService()
void deployBridge(BridgeConfiguration config) throws Exception
Exception
ServerSession getSessionByID(String sessionID)
void threadDump(String reason)
boolean isAddressBound(String address) throws Exception
address
- Exception
void startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,TransportConfiguration> pair, boolean failBackRequest) throws HornetQException
This will spawn a new thread that will sync all persistent data with the new backup. This method may also trigger fail-back if the backup asks for it and the server configuration allows.
rc
- pair
- clusterConnection
- HornetQAlreadyReplicatingException
- if replication is already taking placeHornetQException
void addProtocolManagerFactory(ProtocolManagerFactory factory)
void removeProtocolManagerFactory(ProtocolManagerFactory factory)
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.