HornetQServerImpl (JBoss Application Server: Build 7.1.2.Final API)

Fields
Modifier and Type	Field and Description
`static String`	`GENERIC_IGNORED_FILTER`

Constructors
Constructor and Description
`HornetQServerImpl()`
`HornetQServerImpl(Configuration configuration)`
`HornetQServerImpl(Configuration configuration, HornetQSecurityManager securityManager)`
`HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer)`
`HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer, HornetQSecurityManager securityManager)`

Methods
Modifier and Type	Method and Description
`boolean`	`checkActivate()`
`ReplicationEndpoint`	`connectToReplicationEndpoint(Channel channel)` The journal at the backup server has to be equivalent as the journal used on the live node.
`protected NodeManager`	`createNodeManager(String directory)`
`protected PagingManager`	`createPagingManager()` Protected so tests can change this behaviour
`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)`
`protected StorageManager`	`createStorageManager()` This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)
`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)`
`void`	`destroyDivert(SimpleString name)`
`void`	`destroyQueue(SimpleString queueName, ServerSession session)`
`protected void`	`finalize()`
`HierarchicalRepository<AddressSettings>`	`getAddressSettingsRepository()`
`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()`
`MBeanServer`	`getMBeanServer()`
`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()`
`ServerSession`	`getSessionByID(String sessionName)`
`Set<ServerSession>`	`getSessions()`
`List<ServerSession>`	`getSessions(String connectionID)`
`StorageManager`	`getStorageManager()`
`ExecutorService`	`getThreadPool()`
`Version`	`getVersion()`
`boolean`	`isInitialised()`
`boolean`	`isStarted()`
`boolean`	`isStopped()`
`Queue`	`locateQueue(SimpleString queueName)`
`boolean`	`lookupSession(String key, String value)` will return true if there is any session wth this key
`void`	`registerActivateCallback(ActivateCallback callback)`
`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)` 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.
`void`	`start()`
`void`	`stop()`
`void`	`stop(boolean failoverOnServerShutdown)`
`protected void`	`stop(boolean failoverOnServerShutdown, boolean criticalIOError)`
`void`	`threadDump(String reason)`
`String`	`toString()`
`void`	`unregisterActivateCallback(ActivateCallback callback)`

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
Version:

$Revision: 3543 $
$Id: ServerPeer.java 3543 2008-01-07 22:31:58Z clebert.suconic@jboss.com $

Author:
Tim Fox,
- Field Summary
  
  Fields
  Modifier and Type Field and Description
  
  static String GENERIC_IGNORED_FILTER
  
  Constructor Summary
  
  Constructors
  Constructor and Description
  
  HornetQServerImpl()
  
  HornetQServerImpl(Configuration configuration)
  
  HornetQServerImpl(Configuration configuration, HornetQSecurityManager securityManager)
  
  HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer)
  
  HornetQServerImpl(Configuration configuration, MBeanServer mbeanServer, HornetQSecurityManager securityManager)
  
  Method Summary
  
  Methods
  Modifier and Type Method and Description
  
  boolean checkActivate()
  
  ReplicationEndpoint connectToReplicationEndpoint(Channel channel)
  The journal at the backup server has to be equivalent as the journal used on the live node.
  
  protected NodeManager createNodeManager(String directory)
  
  protected PagingManager createPagingManager()
  Protected so tests can change this behaviour
  
  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)
  
  protected StorageManager createStorageManager()
  This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)
  
  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)
  
  void destroyDivert(SimpleString name)
  
  void destroyQueue(SimpleString queueName, ServerSession session)
  
  protected void finalize()
  
  HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
  
  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()
  
  MBeanServer getMBeanServer()
  
  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()
  
  ServerSession getSessionByID(String sessionName)
  
  Set<ServerSession> getSessions()
  
  List<ServerSession> getSessions(String connectionID)
  
  StorageManager getStorageManager()
  
  ExecutorService getThreadPool()
  
  Version getVersion()
  
  boolean isInitialised()
  
  boolean isStarted()
  
  boolean isStopped()
  
  Queue locateQueue(SimpleString queueName)
  
  boolean lookupSession(String key, String value)
  will return true if there is any session wth this key
  
  void registerActivateCallback(ActivateCallback callback)
  
  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)
  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.
  
  void start()
  
  void stop()
  
  void stop(boolean failoverOnServerShutdown)
  
  protected void stop(boolean failoverOnServerShutdown, boolean criticalIOError)
  
  void threadDump(String reason)
  
  String toString()
  
  void unregisterActivateCallback(ActivateCallback callback)
  
  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
```
  See Also:
  Constant Field Values

Constructor Detail

HornetQServerImpl
```
public HornetQServerImpl()
```

HornetQServerImpl

public HornetQServerImpl(Configuration configuration)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                 MBeanServer mbeanServer)

HornetQServerImpl

public HornetQServerImpl(Configuration configuration,
                 HornetQSecurityManager securityManager)

HornetQServerImpl

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

Method Detail
- createNodeManager
```
protected NodeManager createNodeManager(String directory)
```
- start
```
public void start()
           throws Exception
```
  Specified by:
  
  start in interface HornetQComponent
  
  Throws:
  
  Exception
- finalize
```
protected void finalize()
                 throws Throwable
```
  Overrides:
  
  finalize in class Object
  
  Throws:
  
  Throwable
- stop
```
public void stop()
          throws Exception
```
  Specified by:
  
  stop in interface HornetQComponent
  
  Throws:
  
  Exception
- threadDump
```
public void threadDump(String reason)
```
  Specified by:
  
  threadDump in interface HornetQServer
- stop
```
public void stop(boolean failoverOnServerShutdown)
          throws Exception
```
  Specified by:
  
  stop in interface HornetQServer
  
  Throws:
  
  Exception
- stop
```
protected void stop(boolean failoverOnServerShutdown,
        boolean criticalIOError)
             throws Exception
```
  Throws:
  
  Exception
- describe
```
public String describe()
```
  Specified by:
  
  describe in interface HornetQServer
- setIdentity
```
public void setIdentity(String identity)
```
  Description copied from interface: HornetQServer
  
  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. This identity will be exposed on logs what may help you to debug issues on the log traces and debugs.
  
  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
- getThreadPool
```
public ExecutorService getThreadPool()
```
  Specified by:
  
  getThreadPool in interface HornetQServer
- getConfiguration
```
public Configuration getConfiguration()
```
  Specified by:
  
  getConfiguration in interface HornetQServer
- getMBeanServer
```
public MBeanServer getMBeanServer()
```
  Specified by:
  
  getMBeanServer 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
  
  Specified by:
  
  isStarted in interface HornetQServer
- isStopped
```
public boolean isStopped()
```
  Specified by:
  
  isStopped in interface HornetQServer
- getClusterManager
```
public ClusterManager getClusterManager()
```
  Specified by:
  
  getClusterManager in interface HornetQServer
- 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
- connectToReplicationEndpoint
```
public ReplicationEndpoint connectToReplicationEndpoint(Channel channel)
                                                 throws Exception
```
  Description copied from interface: HornetQServer
  
  The journal at the backup server has to be equivalent as the journal used on the live node. Or else the backup node is out of sync.
  
  Specified by:
  
  connectToReplicationEndpoint in interface HornetQServer
  
  Throws:
  
  Exception
- removeSession
```
public void removeSession(String name)
                   throws Exception
```
  Specified by:
  
  removeSession in interface HornetQServer
  
  Throws:
  
  Exception
- lookupSession
```
public boolean lookupSession(String key,
                    String value)
```
  Description copied from interface: HornetQServer
  
  will return true if there is any session wth this key
  
  Specified by:
  
  lookupSession in interface HornetQServer
- getSessions
```
public List<ServerSession> getSessions(String connectionID)
```
  Specified by:
  
  getSessions in interface HornetQServer
- getSessions
```
public Set<ServerSession> getSessions()
```
  Specified by:
  
  getSessions in interface HornetQServer
- isInitialised
```
public boolean isInitialised()
```
  Specified by:
  
  isInitialised in interface HornetQServer
- getHornetQServerControl
```
public HornetQServerControlImpl getHornetQServerControl()
```
  Description copied from interface: HornetQServer
  
  Returns the resource to manage this HornetQ server. Using this control will throw IllegalStateException if the server is not properly started.
  
  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
- 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,
                ServerSession session)
                  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
- checkActivate
```
public boolean checkActivate()
                      throws Exception
```
  Specified by:
  
  checkActivate in interface HornetQServer
  
  Throws:
  
  Exception
- 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 -
- createPagingManager
```
protected PagingManager createPagingManager()
```
  Protected so tests can change this behaviour
  
  Parameters:
  backupConnector -
- createStorageManager
```
protected StorageManager createStorageManager()
```
  This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)

Class HornetQServerImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

GENERIC_IGNORED_FILTER

Constructor Detail

HornetQServerImpl

HornetQServerImpl

HornetQServerImpl

HornetQServerImpl

HornetQServerImpl

Method Detail

createNodeManager

start

finalize

stop

threadDump

stop

stop

describe

setIdentity

getIdentity

getScheduledPool

getThreadPool

getConfiguration

getMBeanServer

getPagingManager

getRemotingService

getStorageManager

getSecurityManager

getManagementService

getSecurityRepository

getNodeManager

getAddressSettingsRepository

getDeploymentManager

getResourceManager

getVersion

isStarted

isStopped

getClusterManager

createSession

connectToReplicationEndpoint

removeSession

lookupSession

getSessions

getSessions

isInitialised

getHornetQServerControl

getConnectionCount

getPostOffice

getQueueFactory

getNodeID

createQueue

locateQueue

deployQueue

destroyQueue

registerActivateCallback

unregisterActivateCallback

getExecutorFactory

setGroupingHandler

getGroupingHandler

getReplicationEndpoint

getReplicationManager

getConnectorsService

checkActivate

deployDivert

destroyDivert

deployBridge

destroyBridge

getSessionByID

toString

replaceQueueFactory

createPagingManager

createStorageManager