org.hornetq.core.server.impl

Class HornetQServerImpl

java.lang.Object

org.hornetq.core.server.impl.HornetQServerImpl

All Implemented Interfaces:

HornetQComponent, HornetQServer

public class HornetQServerImpl
extends Object
implements HornetQServer

The HornetQ server implementation

Author:

Tim Fox,

Field Summary

Fields

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 Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	addProtocolManagerFactory(ProtocolManagerFactory factory)
boolean	checkLiveIsNotColocated(String nodeId)
protected NodeManager	createNodeManager(String directory, String nodeGroupName, boolean replicatingBackup)
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
ServerSession	createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback)
void	createSharedQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean durable) Creates a transient queue.
void	deployBridge(BridgeConfiguration config)
void	deployDivert(DivertConfiguration config)
Queue	deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
String	describe()
void	destroyBridge(String name)
String	destroyConnectionWithSessionMetadata(String metaKey, String parameterValue)
void	destroyDivert(SimpleString name)
void	destroyQueue(SimpleString queueName)
void	destroyQueue(SimpleString queueName, ServerSession session)
void	destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount)
void	destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount, boolean removeConsumers)
protected void	finalize()
HierarchicalRepository<AddressSettings>	getAddressSettingsRepository()
BackupManager	getBackupManager()
ClusterManager	getClusterManager()
Configuration	getConfiguration()
int	getConnectionCount()
ConnectorsService	getConnectorsService()
DeploymentManager	getDeploymentManager()
ExecutorFactory	getExecutorFactory()
GroupingHandler	getGroupingHandler()
HornetQServerControlImpl	getHornetQServerControl() Returns the resource to manage this HornetQ server.
String	getIdentity()
ManagementService	getManagementService()
SimpleString	getNodeID()
NodeManager	getNodeManager()
PagingManager	getPagingManager()
PostOffice	getPostOffice()
QueueFactory	getQueueFactory()
RemotingService	getRemotingService()
ReplicationEndpoint	getReplicationEndpoint()
ReplicationManager	getReplicationManager()
ResourceManager	getResourceManager()
ScheduledExecutorService	getScheduledPool()
HornetQSecurityManager	getSecurityManager()
HierarchicalRepository<Set<Role>>	getSecurityRepository()
protected SecurityStore	getSecurityStore()
ServerSession	getSessionByID(String sessionName)
Set<ServerSession>	getSessions()
List<ServerSession>	getSessions(String connectionID)
StorageManager	getStorageManager()
Version	getVersion()
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)
boolean	isActive()
boolean	isAddressBound(String address) return true if there is a binding for this address (i.e.
boolean	isRemoteBackupUpToDate() Whether a remote backup server was in sync with its live server.
boolean	isStarted()
Queue	locateQueue(SimpleString queueName)
ServerSession	lookupSession(String key, String value)
void	registerActivateCallback(ActivateCallback callback)
void	remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)
void	removeProtocolManagerFactory(ProtocolManagerFactory factory)
void	removeSession(String name)
void	replaceQueueFactory(QueueFactory factory) For tests only, don't use this method as it's not part of the API
void	setGroupingHandler(GroupingHandler groupingHandler)
void	setIdentity(String identity) Sets the server identity.
void	setRemoteBackupUpToDate()
void	start()
protected void	startBackupServers(Configuration configuration, Map<String,HornetQServer> backupServers)
void	startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,TransportConfiguration> pair, boolean isFailBackRequest) Starts replication.
void	stop()
void	stop(boolean failoverOnServerShutdown)
void	stopTheServer(boolean criticalIOError) Stops the server in a different thread.
void	threadDump(String reason)
String	toString()
void	unregisterActivateCallback(ActivateCallback callback)
boolean	waitForActivation(long timeout, TimeUnit unit) Wait for server initialization.
boolean	waitForBackupSync(long timeout, TimeUnit unit) Wait for backup synchronization when using synchronization

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

GENERIC_IGNORED_FILTER

public static final 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. That subscription needs an invalid filter, however paging needs to ignore any subscription with this filter. For that reason, this filter needs to be rejected on paging or any other component on the system, and just be ignored for any purpose It's declared here as this filter is considered a global ignore

See Also:

Constant Field Values

Constructor Detail

HornetQServerImpl

public HornetQServerImpl()

HornetQServerImpl

public HornetQServerImpl(Configuration configuration)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                         HornetQServer parentServer)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                         MBeanServer mbeanServer)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                         HornetQSecurityManager securityManager)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                         MBeanServer mbeanServer,
                         HornetQSecurityManager securityManager)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                         MBeanServer mbeanServer,
                         HornetQSecurityManager securityManager,
                         HornetQServer parentServer)

Method Detail

createNodeManager

protected NodeManager createNodeManager(String directory,
                                        String nodeGroupName,
                                        boolean replicatingBackup)

start

public final void start()
                 throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

finalize

protected final void finalize()
                       throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

stopTheServer

public final void stopTheServer(boolean criticalIOError)

Stops the server in a different thread.

stop

public final void stop()
                throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isAddressBound

public boolean isAddressBound(String address)
                       throws Exception

Description copied from interface: HornetQServer

return true if there is a binding for this address (i.e. if there is a created queue)

Specified by:

isAddressBound in interface HornetQServer

Returns:

Throws:

Exception

threadDump

public void threadDump(String reason)

Specified by:

threadDump in interface HornetQServer

stop

public final void stop(boolean failoverOnServerShutdown)
                throws Exception

Specified by:

stop in interface HornetQServer

Throws:

Exception

checkLiveIsNotColocated

public boolean checkLiveIsNotColocated(String nodeId)

describe

public String describe()

Specified by:

describe in interface HornetQServer

destroyConnectionWithSessionMetadata

public String destroyConnectionWithSessionMetadata(String metaKey,
                                                   String parameterValue)
                                            throws Exception

Specified by:

destroyConnectionWithSessionMetadata in interface HornetQServer

Throws:

Exception

setIdentity

public void setIdentity(String identity)

Description copied from interface: HornetQServer

Sets the server 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.

Specified by:

setIdentity in interface HornetQServer

getIdentity

public String getIdentity()

Specified by:

getIdentity in interface HornetQServer

getScheduledPool

public ScheduledExecutorService getScheduledPool()

Specified by:

getScheduledPool in interface HornetQServer

getConfiguration

public Configuration getConfiguration()

Specified by:

getConfiguration in interface HornetQServer

getPagingManager

public PagingManager getPagingManager()

Specified by:

getPagingManager in interface HornetQServer

getRemotingService

public RemotingService getRemotingService()

Specified by:

getRemotingService in interface HornetQServer

getStorageManager

public StorageManager getStorageManager()

Specified by:

getStorageManager in interface HornetQServer

getSecurityManager

public HornetQSecurityManager getSecurityManager()

Specified by:

getSecurityManager in interface HornetQServer

getManagementService

public ManagementService getManagementService()

Specified by:

getManagementService in interface HornetQServer

getSecurityRepository

public HierarchicalRepository<Set<Role>> getSecurityRepository()

Specified by:

getSecurityRepository in interface HornetQServer

getNodeManager

public NodeManager getNodeManager()

Specified by:

getNodeManager in interface HornetQServer

getAddressSettingsRepository

public HierarchicalRepository<AddressSettings> getAddressSettingsRepository()

Specified by:

getAddressSettingsRepository in interface HornetQServer

getDeploymentManager

public DeploymentManager getDeploymentManager()

getResourceManager

public ResourceManager getResourceManager()

Specified by:

getResourceManager in interface HornetQServer

getVersion

public Version getVersion()

Specified by:

getVersion in interface HornetQServer

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getClusterManager

public ClusterManager getClusterManager()

Specified by:

getClusterManager in interface HornetQServer

getBackupManager

public BackupManager getBackupManager()

createSession

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

Specified by:

createSession in interface HornetQServer

Throws:

Exception

internalCreateSession

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

Throws:

Exception

getSecurityStore

protected SecurityStore getSecurityStore()

removeSession

public void removeSession(String name)
                   throws Exception

Specified by:

removeSession in interface HornetQServer

Throws:

Exception

lookupSession

public ServerSession lookupSession(String key,
                                   String value)

Specified by:

lookupSession in interface HornetQServer

Returns:

a session containing the meta-key and meata-value

getSessions

public List<ServerSession> getSessions(String connectionID)

Specified by:

getSessions in interface HornetQServer

getSessions

public Set<ServerSession> getSessions()

Specified by:

getSessions in interface HornetQServer

isActive

public boolean isActive()

Specified by:

isActive in interface HornetQServer

waitForActivation

public boolean waitForActivation(long timeout,
                                 TimeUnit unit)
                          throws InterruptedException

Description copied from interface: HornetQServer

Wait for server initialization.

Specified by:

waitForActivation in interface HornetQServer

Returns:

true if the server was already initialized or if it was initialized within the timeout period, false otherwise.

Throws:

InterruptedException

See Also:

CountDownLatch#await(long, TimeUnit)

waitForBackupSync

public boolean waitForBackupSync(long timeout,
                                 TimeUnit unit)
                          throws InterruptedException

Description copied from interface: HornetQServer

Wait for backup synchronization when using synchronization

Specified by:

waitForBackupSync in interface HornetQServer

Returns:

true if the server was already initialized or if it was initialized within the timeout period, false otherwise.

Throws:

InterruptedException

See Also:

CountDownLatch#await(long, TimeUnit)

getHornetQServerControl

public HornetQServerControlImpl getHornetQServerControl()

Description copied from interface: HornetQServer

Returns the resource to manage this HornetQ server.

Specified by:

getHornetQServerControl in interface HornetQServer

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface HornetQServer

getPostOffice

public PostOffice getPostOffice()

Specified by:

getPostOffice in interface HornetQServer

getQueueFactory

public QueueFactory getQueueFactory()

Specified by:

getQueueFactory in interface HornetQServer

getNodeID

public SimpleString getNodeID()

Specified by:

getNodeID in interface HornetQServer

createQueue

public Queue createQueue(SimpleString address,
                         SimpleString queueName,
                         SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws Exception

Specified by:

createQueue in interface HornetQServer

Throws:

Exception

createSharedQueue

public void createSharedQueue(SimpleString address,
                              SimpleString name,
                              SimpleString filterString,
                              boolean durable)
                       throws Exception

Creates a transient queue. A queue that will exist as long as there are consumers. The queue will be deleted as soon as all the consumers are removed.

Notice: the queue won't be deleted until the first consumer arrives.

Specified by:

createSharedQueue in interface HornetQServer

Parameters:

address -

name -

filterString -

durable -

Throws:

Exception

locateQueue

public Queue locateQueue(SimpleString queueName)
                  throws Exception

Specified by:

locateQueue in interface HornetQServer

Throws:

Exception

deployQueue

public Queue deployQueue(SimpleString address,
                         SimpleString queueName,
                         SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws Exception

Specified by:

deployQueue in interface HornetQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName)
                  throws Exception

Specified by:

destroyQueue in interface HornetQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
                         ServerSession session)
                  throws Exception

Specified by:

destroyQueue in interface HornetQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
                         ServerSession session,
                         boolean checkConsumerCount)
                  throws Exception

Specified by:

destroyQueue in interface HornetQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
                         ServerSession session,
                         boolean checkConsumerCount,
                         boolean removeConsumers)
                  throws Exception

Specified by:

destroyQueue in interface HornetQServer

Throws:

Exception

registerActivateCallback

public void registerActivateCallback(ActivateCallback callback)

Specified by:

registerActivateCallback in interface HornetQServer

unregisterActivateCallback

public void unregisterActivateCallback(ActivateCallback callback)

Specified by:

unregisterActivateCallback in interface HornetQServer

getExecutorFactory

public ExecutorFactory getExecutorFactory()

Specified by:

getExecutorFactory in interface HornetQServer

setGroupingHandler

public void setGroupingHandler(GroupingHandler groupingHandler)

Specified by:

setGroupingHandler in interface HornetQServer

getGroupingHandler

public GroupingHandler getGroupingHandler()

Specified by:

getGroupingHandler in interface HornetQServer

getReplicationEndpoint

public ReplicationEndpoint getReplicationEndpoint()

Specified by:

getReplicationEndpoint in interface HornetQServer

getReplicationManager

public ReplicationManager getReplicationManager()

Specified by:

getReplicationManager in interface HornetQServer

getConnectorsService

public ConnectorsService getConnectorsService()

Specified by:

getConnectorsService in interface HornetQServer

deployDivert

public void deployDivert(DivertConfiguration config)
                  throws Exception

Specified by:

deployDivert in interface HornetQServer

Throws:

Exception

destroyDivert

public void destroyDivert(SimpleString name)
                   throws Exception

Specified by:

destroyDivert in interface HornetQServer

Throws:

Exception

deployBridge

public void deployBridge(BridgeConfiguration config)
                  throws Exception

Specified by:

deployBridge in interface HornetQServer

Throws:

Exception

destroyBridge

public void destroyBridge(String name)
                   throws Exception

Specified by:

destroyBridge in interface HornetQServer

Throws:

Exception

getSessionByID

public ServerSession getSessionByID(String sessionName)

Specified by:

getSessionByID in interface HornetQServer

toString

public String toString()

Overrides:

toString in class Object

replaceQueueFactory

public void replaceQueueFactory(QueueFactory factory)

For tests only, don't use this method as it's not part of the API

Parameters:

factory -

startBackupServers

protected void startBackupServers(Configuration configuration,
                                  Map<String,HornetQServer> backupServers)

startReplication

public void startReplication(CoreRemotingConnection rc,
                             ClusterConnection clusterConnection,
                             Pair<TransportConfiguration,TransportConfiguration> pair,
                             boolean isFailBackRequest)
                      throws HornetQException

Description copied from interface: HornetQServer

Starts replication.

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.

Specified by:

startReplication in interface HornetQServer

Throws:

HornetQException

isRemoteBackupUpToDate

public boolean isRemoteBackupUpToDate()

Whether a remote backup server was in sync with its live server. If it was not in sync, it may not take over the live's functions.

A local backup server or a live server should always return true

Returns:

whether the backup is up-to-date, if the server is not a backup it always returns true.

setRemoteBackupUpToDate

public void setRemoteBackupUpToDate()

addProtocolManagerFactory

public void addProtocolManagerFactory(ProtocolManagerFactory factory)

Specified by:

addProtocolManagerFactory in interface HornetQServer

removeProtocolManagerFactory

public void removeProtocolManagerFactory(ProtocolManagerFactory factory)

Specified by:

removeProtocolManagerFactory in interface HornetQServer

remoteFailOver

public void remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)
                    throws HornetQException

Throws:

HornetQException