public class HornetQServerImpl extends Object implements HornetQServer
Modifier and Type | Field and Description |
---|---|
static String |
GENERIC_IGNORED_FILTER
JMS Topics (which are outside of the scope of the core API) will require a dumb subscription
with a dummy-filter at this current version as a way to keep its existence valid and TCK
tests.
|
Constructor and Description |
---|
HornetQServerImpl() |
HornetQServerImpl(Configuration configuration) |
HornetQServerImpl(Configuration configuration,
HornetQSecurityManager securityManager) |
HornetQServerImpl(Configuration configuration,
HornetQServer parentServer) |
HornetQServerImpl(Configuration configuration,
MBeanServer mbeanServer) |
HornetQServerImpl(Configuration configuration,
MBeanServer mbeanServer,
HornetQSecurityManager securityManager) |
HornetQServerImpl(Configuration configuration,
MBeanServer mbeanServer,
HornetQSecurityManager securityManager,
HornetQServer parentServer) |
public static final String GENERIC_IGNORED_FILTER
public HornetQServerImpl()
public HornetQServerImpl(Configuration configuration)
public HornetQServerImpl(Configuration configuration, HornetQServer parentServer)
public HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer)
public HornetQServerImpl(Configuration configuration, HornetQSecurityManager securityManager)
public HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer, HornetQSecurityManager securityManager)
public HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer, HornetQSecurityManager securityManager, HornetQServer parentServer)
protected NodeManager createNodeManager(String directory, String nodeGroupName, boolean replicatingBackup)
public final void start() throws Exception
start
in interface HornetQComponent
Exception
protected final void finalize() throws Throwable
public final void stopTheServer(boolean criticalIOError)
public final void stop() throws Exception
stop
in interface HornetQComponent
Exception
public boolean isAddressBound(String address) throws Exception
HornetQServer
isAddressBound
in interface HornetQServer
Exception
public void threadDump(String reason)
threadDump
in interface HornetQServer
public final void stop(boolean failoverOnServerShutdown) throws Exception
stop
in interface HornetQServer
Exception
public boolean checkLiveIsNotColocated(String nodeId)
public String describe()
describe
in interface HornetQServer
public String destroyConnectionWithSessionMetadata(String metaKey, String parameterValue) throws Exception
destroyConnectionWithSessionMetadata
in interface HornetQServer
Exception
public void setIdentity(String identity)
HornetQServer
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.
setIdentity
in interface HornetQServer
public String getIdentity()
getIdentity
in interface HornetQServer
public ScheduledExecutorService getScheduledPool()
getScheduledPool
in interface HornetQServer
public Configuration getConfiguration()
getConfiguration
in interface HornetQServer
public PagingManager getPagingManager()
getPagingManager
in interface HornetQServer
public RemotingService getRemotingService()
getRemotingService
in interface HornetQServer
public StorageManager getStorageManager()
getStorageManager
in interface HornetQServer
public HornetQSecurityManager getSecurityManager()
getSecurityManager
in interface HornetQServer
public ManagementService getManagementService()
getManagementService
in interface HornetQServer
public HierarchicalRepository<Set<Role>> getSecurityRepository()
getSecurityRepository
in interface HornetQServer
public NodeManager getNodeManager()
getNodeManager
in interface HornetQServer
public HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
getAddressSettingsRepository
in interface HornetQServer
public DeploymentManager getDeploymentManager()
public ResourceManager getResourceManager()
getResourceManager
in interface HornetQServer
public Version getVersion()
getVersion
in interface HornetQServer
public boolean isStarted()
isStarted
in interface HornetQComponent
public ClusterManager getClusterManager()
getClusterManager
in interface HornetQServer
public BackupManager getBackupManager()
public ServerSession createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback) throws Exception
createSession
in interface HornetQServer
Exception
protected ServerSessionImpl internalCreateSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, OperationContext context) throws Exception
Exception
protected SecurityStore getSecurityStore()
public void removeSession(String name) throws Exception
removeSession
in interface HornetQServer
Exception
public ServerSession lookupSession(String key, String value)
lookupSession
in interface HornetQServer
public List<ServerSession> getSessions(String connectionID)
getSessions
in interface HornetQServer
public Set<ServerSession> getSessions()
getSessions
in interface HornetQServer
public boolean isActive()
isActive
in interface HornetQServer
public boolean waitForActivation(long timeout, TimeUnit unit) throws InterruptedException
HornetQServer
waitForActivation
in interface HornetQServer
true
if the server was already initialized or if it was initialized within the
timeout period, false
otherwise.InterruptedException
CountDownLatch#await(long, TimeUnit)
public boolean waitForBackupSync(long timeout, TimeUnit unit) throws InterruptedException
HornetQServer
waitForBackupSync
in interface HornetQServer
true
if the server was already initialized or if it was initialized within the
timeout period, false
otherwise.InterruptedException
CountDownLatch#await(long, TimeUnit)
public HornetQServerControlImpl getHornetQServerControl()
HornetQServer
getHornetQServerControl
in interface HornetQServer
public int getConnectionCount()
getConnectionCount
in interface HornetQServer
public PostOffice getPostOffice()
getPostOffice
in interface HornetQServer
public QueueFactory getQueueFactory()
getQueueFactory
in interface HornetQServer
public SimpleString getNodeID()
getNodeID
in interface HornetQServer
public Queue createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) throws Exception
createQueue
in interface HornetQServer
Exception
public void createSharedQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean durable) throws Exception
createSharedQueue
in interface HornetQServer
address
- name
- filterString
- durable
- Exception
public Queue locateQueue(SimpleString queueName) throws Exception
locateQueue
in interface HornetQServer
Exception
public Queue deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) throws Exception
deployQueue
in interface HornetQServer
Exception
public void destroyQueue(SimpleString queueName) throws Exception
destroyQueue
in interface HornetQServer
Exception
public void destroyQueue(SimpleString queueName, ServerSession session) throws Exception
destroyQueue
in interface HornetQServer
Exception
public void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount) throws Exception
destroyQueue
in interface HornetQServer
Exception
public void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount, boolean removeConsumers) throws Exception
destroyQueue
in interface HornetQServer
Exception
public void registerActivateCallback(ActivateCallback callback)
registerActivateCallback
in interface HornetQServer
public void unregisterActivateCallback(ActivateCallback callback)
unregisterActivateCallback
in interface HornetQServer
public ExecutorFactory getExecutorFactory()
getExecutorFactory
in interface HornetQServer
public void setGroupingHandler(GroupingHandler groupingHandler)
setGroupingHandler
in interface HornetQServer
public GroupingHandler getGroupingHandler()
getGroupingHandler
in interface HornetQServer
public ReplicationEndpoint getReplicationEndpoint()
getReplicationEndpoint
in interface HornetQServer
public ReplicationManager getReplicationManager()
getReplicationManager
in interface HornetQServer
public ConnectorsService getConnectorsService()
getConnectorsService
in interface HornetQServer
public void deployDivert(DivertConfiguration config) throws Exception
deployDivert
in interface HornetQServer
Exception
public void destroyDivert(SimpleString name) throws Exception
destroyDivert
in interface HornetQServer
Exception
public void deployBridge(BridgeConfiguration config) throws Exception
deployBridge
in interface HornetQServer
Exception
public void destroyBridge(String name) throws Exception
destroyBridge
in interface HornetQServer
Exception
public ServerSession getSessionByID(String sessionName)
getSessionByID
in interface HornetQServer
public void replaceQueueFactory(QueueFactory factory)
factory
- protected void startBackupServers(Configuration configuration, Map<String,HornetQServer> backupServers)
public void startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,TransportConfiguration> pair, boolean isFailBackRequest) throws HornetQException
HornetQServer
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.
startReplication
in interface HornetQServer
HornetQException
public boolean isRemoteBackupUpToDate()
true
true
.public void setRemoteBackupUpToDate()
public void addProtocolManagerFactory(ProtocolManagerFactory factory)
addProtocolManagerFactory
in interface HornetQServer
public void removeProtocolManagerFactory(ProtocolManagerFactory factory)
removeProtocolManagerFactory
in interface HornetQServer
public void remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage) throws HornetQException
HornetQException
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.