org.jboss.messaging.core.server.impl
Class MessagingServerImpl

java.lang.Object
  extended by org.jboss.messaging.core.server.impl.MessagingServerImpl
All Implemented Interfaces:
MessagingComponent, MessagingServer

public class MessagingServerImpl
extends java.lang.Object
implements MessagingServer

The messaging server implementation

Version:
$Revision: 3543 $

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

Author:
Tim Fox,
Constructor Summary
MessagingServerImpl()
           
MessagingServerImpl(Configuration configuration)
           
MessagingServerImpl(Configuration configuration, JBMSecurityManager securityManager)
           
MessagingServerImpl(Configuration configuration, javax.management.MBeanServer mbeanServer)
           
MessagingServerImpl(Configuration configuration, javax.management.MBeanServer mbeanServer, JBMSecurityManager securityManager)
           
 
Method Summary
protected  PagingManager createPagingManager()
           
 Queue createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
           
 CreateSessionResponseMessage createSession(java.lang.String name, long channelID, long replicatedChannelID, java.lang.String username, java.lang.String password, int minLargeMessageSize, int incrementingVersion, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, int sendWindowSize)
           
 Queue deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
           
 void destroyQueue(SimpleString queueName, ServerSession session)
           
 HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
           
 ClusterManager getClusterManager()
           
 Configuration getConfiguration()
           
 int getConnectionCount()
           
 DeploymentManager getDeploymentManager()
           
 ManagementService getManagementService()
           
 javax.management.MBeanServer getMBeanServer()
           
 MessagingServerControlImpl getMessagingServerControl()
           
 SimpleString getNodeID()
           
 PostOffice getPostOffice()
           
 QueueFactory getQueueFactory()
           
 RemotingService getRemotingService()
           
 Channel getReplicatingChannel()
           
 ResourceManager getResourceManager()
           
 JBMSecurityManager getSecurityManager()
           
 HierarchicalRepository<java.util.Set<Role>> getSecurityRepository()
           
 ServerSession getSession(java.lang.String name)
           
 java.util.Set<ServerSession> getSessions()
           
 java.util.List<ServerSession> getSessions(java.lang.String connectionID)
           
 StorageManager getStorageManager()
           
 Version getVersion()
           
 void handleReplicateRedistribution(SimpleString queueName, long messageID)
           
 void initialiseBackup(UUID theUUID, long liveUniqueID)
           
 boolean isInitialised()
           
 boolean isStarted()
           
 ReattachSessionResponseMessage reattachSession(RemotingConnection connection, java.lang.String name, int lastReceivedCommandID)
           
 void registerActivateCallback(ActivateCallback callback)
           
 void removeSession(java.lang.String name)
           
 void replicateCreateSession(java.lang.String name, long replicatedChannelID, long originalChannelID, java.lang.String username, java.lang.String password, int minLargeMessageSize, int incrementingVersion, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, int producerWindowSize)
           
 void start()
           
 void stop()
           
 void unregisterActivateCallback(ActivateCallback callback)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessagingServerImpl

public MessagingServerImpl()

MessagingServerImpl

public MessagingServerImpl(Configuration configuration)

MessagingServerImpl

public MessagingServerImpl(Configuration configuration,
                           javax.management.MBeanServer mbeanServer)

MessagingServerImpl

public MessagingServerImpl(Configuration configuration,
                           JBMSecurityManager securityManager)

MessagingServerImpl

public MessagingServerImpl(Configuration configuration,
                           javax.management.MBeanServer mbeanServer,
                           JBMSecurityManager securityManager)
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface MessagingComponent
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface MessagingComponent
Throws:
java.lang.Exception

getConfiguration

public Configuration getConfiguration()
Specified by:
getConfiguration in interface MessagingServer

getMBeanServer

public javax.management.MBeanServer getMBeanServer()
Specified by:
getMBeanServer in interface MessagingServer

getRemotingService

public RemotingService getRemotingService()
Specified by:
getRemotingService in interface MessagingServer

getStorageManager

public StorageManager getStorageManager()
Specified by:
getStorageManager in interface MessagingServer

getSecurityManager

public JBMSecurityManager getSecurityManager()
Specified by:
getSecurityManager in interface MessagingServer

getManagementService

public ManagementService getManagementService()
Specified by:
getManagementService in interface MessagingServer

getSecurityRepository

public HierarchicalRepository<java.util.Set<Role>> getSecurityRepository()
Specified by:
getSecurityRepository in interface MessagingServer

getAddressSettingsRepository

public HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
Specified by:
getAddressSettingsRepository in interface MessagingServer

getDeploymentManager

public DeploymentManager getDeploymentManager()

getResourceManager

public ResourceManager getResourceManager()
Specified by:
getResourceManager in interface MessagingServer

getVersion

public Version getVersion()
Specified by:
getVersion in interface MessagingServer

isStarted

public boolean isStarted()
Specified by:
isStarted in interface MessagingComponent
Specified by:
isStarted in interface MessagingServer

getClusterManager

public ClusterManager getClusterManager()
Specified by:
getClusterManager in interface MessagingServer

reattachSession

public ReattachSessionResponseMessage reattachSession(RemotingConnection connection,
                                                      java.lang.String name,
                                                      int lastReceivedCommandID)
                                               throws java.lang.Exception
Specified by:
reattachSession in interface MessagingServer
Throws:
java.lang.Exception

replicateCreateSession

public void replicateCreateSession(java.lang.String name,
                                   long replicatedChannelID,
                                   long originalChannelID,
                                   java.lang.String username,
                                   java.lang.String password,
                                   int minLargeMessageSize,
                                   int incrementingVersion,
                                   RemotingConnection connection,
                                   boolean autoCommitSends,
                                   boolean autoCommitAcks,
                                   boolean preAcknowledge,
                                   boolean xa,
                                   int producerWindowSize)
                            throws java.lang.Exception
Specified by:
replicateCreateSession in interface MessagingServer
Throws:
java.lang.Exception

createSession

public CreateSessionResponseMessage createSession(java.lang.String name,
                                                  long channelID,
                                                  long replicatedChannelID,
                                                  java.lang.String username,
                                                  java.lang.String password,
                                                  int minLargeMessageSize,
                                                  int incrementingVersion,
                                                  RemotingConnection connection,
                                                  boolean autoCommitSends,
                                                  boolean autoCommitAcks,
                                                  boolean preAcknowledge,
                                                  boolean xa,
                                                  int sendWindowSize)
                                           throws java.lang.Exception
Specified by:
createSession in interface MessagingServer
Throws:
java.lang.Exception

removeSession

public void removeSession(java.lang.String name)
                   throws java.lang.Exception
Specified by:
removeSession in interface MessagingServer
Throws:
java.lang.Exception

getSession

public ServerSession getSession(java.lang.String name)
Specified by:
getSession in interface MessagingServer

getSessions

public java.util.List<ServerSession> getSessions(java.lang.String connectionID)
Specified by:
getSessions in interface MessagingServer

getSessions

public java.util.Set<ServerSession> getSessions()
Specified by:
getSessions in interface MessagingServer

isInitialised

public boolean isInitialised()
Specified by:
isInitialised in interface MessagingServer

initialiseBackup

public void initialiseBackup(UUID theUUID,
                             long liveUniqueID)
                      throws java.lang.Exception
Specified by:
initialiseBackup in interface MessagingServer
Throws:
java.lang.Exception

getMessagingServerControl

public MessagingServerControlImpl getMessagingServerControl()
Specified by:
getMessagingServerControl in interface MessagingServer

getConnectionCount

public int getConnectionCount()
Specified by:
getConnectionCount in interface MessagingServer

getPostOffice

public PostOffice getPostOffice()
Specified by:
getPostOffice in interface MessagingServer

getQueueFactory

public QueueFactory getQueueFactory()
Specified by:
getQueueFactory in interface MessagingServer

getNodeID

public SimpleString getNodeID()
Specified by:
getNodeID in interface MessagingServer

handleReplicateRedistribution

public void handleReplicateRedistribution(SimpleString queueName,
                                          long messageID)
                                   throws java.lang.Exception
Specified by:
handleReplicateRedistribution in interface MessagingServer
Throws:
java.lang.Exception

createQueue

public Queue createQueue(SimpleString address,
                         SimpleString queueName,
                         SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws java.lang.Exception
Specified by:
createQueue in interface MessagingServer
Throws:
java.lang.Exception

deployQueue

public Queue deployQueue(SimpleString address,
                         SimpleString queueName,
                         SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws java.lang.Exception
Specified by:
deployQueue in interface MessagingServer
Throws:
java.lang.Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
                         ServerSession session)
                  throws java.lang.Exception
Specified by:
destroyQueue in interface MessagingServer
Throws:
java.lang.Exception

registerActivateCallback

public void registerActivateCallback(ActivateCallback callback)
Specified by:
registerActivateCallback in interface MessagingServer

unregisterActivateCallback

public void unregisterActivateCallback(ActivateCallback callback)
Specified by:
unregisterActivateCallback in interface MessagingServer

createPagingManager

protected PagingManager createPagingManager()

getReplicatingChannel

public Channel getReplicatingChannel()
Specified by:
getReplicatingChannel in interface MessagingServer


Copyright © 2006 JBoss Inc. All Rights Reserved.