org.hornetq.core.server

Interface HornetQServer

All Superinterfaces:

HornetQComponent

All Known Implementing Classes:

HornetQServerImpl

public interface HornetQServer
extends HornetQComponent

This interface defines the internal interface of the HornetQ Server exposed to other components of the server. The external management interface of the HornetQ Server is defined by the HornetQServerManagement interface This interface is never exposed outside the HornetQ server, e.g. by JMX or other means

Author:

Tim Fox, Andy Taylor

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.
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)
ServerSession	createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback)
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)
HierarchicalRepository<AddressSettings>	getAddressSettingsRepository()
ClusterManager	getClusterManager()
Configuration	getConfiguration()
int	getConnectionCount()
ConnectorsService	getConnectorsService()
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 sessionID)
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 metakey, String metavalue) will return true if there is any session wth this key
void	registerActivateCallback(ActivateCallback callback)
void	removeSession(String name)
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	stop(boolean failoverOnServerShutdown)
void	threadDump(String reason)
void	unregisterActivateCallback(ActivateCallback callback)

Methods inherited from interface org.hornetq.core.server.HornetQComponent

start, stop

Method Detail

setIdentity

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. This identity will be exposed on logs what may help you to debug issues on the log traces and debugs.

getIdentity

String getIdentity()

describe

String describe()

getConfiguration

Configuration getConfiguration()

getRemotingService

RemotingService getRemotingService()

getStorageManager

StorageManager getStorageManager()

getPagingManager

PagingManager getPagingManager()

getManagementService

ManagementService getManagementService()

getSecurityManager

HornetQSecurityManager getSecurityManager()

getMBeanServer

MBeanServer getMBeanServer()

getVersion

Version getVersion()

getNodeManager

NodeManager getNodeManager()

getHornetQServerControl

HornetQServerControlImpl getHornetQServerControl()

Returns the resource to manage this HornetQ server. Using this control will throw IllegalStateException if the server is not properly started.

registerActivateCallback

void registerActivateCallback(ActivateCallback callback)

unregisterActivateCallback

void unregisterActivateCallback(ActivateCallback callback)

connectToReplicationEndpoint

ReplicationEndpoint connectToReplicationEndpoint(Channel channel)
                                                 throws Exception

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.

Throws:

Exception

createSession

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

Throws:

Exception

removeSession

void removeSession(String name)
                   throws Exception

Throws:

Exception

getSessions

Set<ServerSession> getSessions()

isStarted

boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

isStopped

boolean isStopped()

getSecurityRepository

HierarchicalRepository<Set<Role>> getSecurityRepository()

getAddressSettingsRepository

HierarchicalRepository<AddressSettings> getAddressSettingsRepository()

getConnectionCount

int getConnectionCount()

getPostOffice

PostOffice getPostOffice()

getQueueFactory

QueueFactory getQueueFactory()

getResourceManager

ResourceManager getResourceManager()

getSessions

List<ServerSession> getSessions(String connectionID)

lookupSession

boolean lookupSession(String metakey,
                    String metavalue)

will return true if there is any session wth this key

getClusterManager

ClusterManager getClusterManager()

getNodeID

SimpleString getNodeID()

isInitialised

boolean isInitialised()

createQueue

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

Throws:

Exception

deployQueue

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

Throws:

Exception

locateQueue

Queue locateQueue(SimpleString queueName)
                  throws Exception

Throws:

Exception

destroyQueue

void destroyQueue(SimpleString queueName,
                ServerSession session)
                  throws Exception

Throws:

Exception

getScheduledPool

ScheduledExecutorService getScheduledPool()

getThreadPool

ExecutorService getThreadPool()

getExecutorFactory

ExecutorFactory getExecutorFactory()

setGroupingHandler

void setGroupingHandler(GroupingHandler groupingHandler)

getGroupingHandler

GroupingHandler getGroupingHandler()

getReplicationEndpoint

ReplicationEndpoint getReplicationEndpoint()

getReplicationManager

ReplicationManager getReplicationManager()

checkActivate

boolean checkActivate()
                      throws Exception

Throws:

Exception

deployDivert

void deployDivert(DivertConfiguration config)
                  throws Exception

Throws:

Exception

destroyDivert

void destroyDivert(SimpleString name)
                   throws Exception

Throws:

Exception

getConnectorsService

ConnectorsService getConnectorsService()

deployBridge

void deployBridge(BridgeConfiguration config)
                  throws Exception

Throws:

Exception

destroyBridge

void destroyBridge(String name)
                   throws Exception

Throws:

Exception

getSessionByID

ServerSession getSessionByID(String sessionID)

threadDump

void threadDump(String reason)

stop

void stop(boolean failoverOnServerShutdown)
          throws Exception

Throws:

Exception