org.jboss.messaging.core.server
Interface MessagingServer
- All Superinterfaces:
- MessagingComponent
- All Known Implementing Classes:
- MessagingServerImpl
public interface MessagingServer
- extends MessagingComponent
This interface defines the internal interface of the Messaging Server exposed to other components of the server. The
external management interface of the Messaging Server is defined by the MessagingServerManagement interface This
interface is never exposed outside the messaging server, e.g. by JMX or other means
- Author:
- Tim Fox, Andy Taylor
Method Summary |
Queue |
createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
|
CreateSessionResponseMessage |
createSession(java.lang.String name,
long channelID,
long replicatedSessionID,
java.lang.String username,
java.lang.String password,
int minLargeMessageSize,
int incrementingVersion,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
int producerWindowSize)
|
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()
|
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 nodeID,
long currentMessageID)
|
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 channelID,
long originalSessionID,
java.lang.String username,
java.lang.String password,
int minLargeMessageSize,
int incrementingVersion,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
int sendWindowSize)
|
void |
unregisterActivateCallback(ActivateCallback callback)
|
getConfiguration
Configuration getConfiguration()
getRemotingService
RemotingService getRemotingService()
getStorageManager
StorageManager getStorageManager()
getManagementService
ManagementService getManagementService()
getSecurityManager
JBMSecurityManager getSecurityManager()
getMBeanServer
javax.management.MBeanServer getMBeanServer()
getVersion
Version getVersion()
getMessagingServerControl
MessagingServerControlImpl getMessagingServerControl()
registerActivateCallback
void registerActivateCallback(ActivateCallback callback)
unregisterActivateCallback
void unregisterActivateCallback(ActivateCallback callback)
reattachSession
ReattachSessionResponseMessage reattachSession(RemotingConnection connection,
java.lang.String name,
int lastReceivedCommandID)
throws java.lang.Exception
- Throws:
java.lang.Exception
createSession
CreateSessionResponseMessage createSession(java.lang.String name,
long channelID,
long replicatedSessionID,
java.lang.String username,
java.lang.String password,
int minLargeMessageSize,
int incrementingVersion,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
int producerWindowSize)
throws java.lang.Exception
- Throws:
java.lang.Exception
replicateCreateSession
void replicateCreateSession(java.lang.String name,
long channelID,
long originalSessionID,
java.lang.String username,
java.lang.String password,
int minLargeMessageSize,
int incrementingVersion,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
int sendWindowSize)
throws java.lang.Exception
- Throws:
java.lang.Exception
removeSession
void removeSession(java.lang.String name)
throws java.lang.Exception
- Throws:
java.lang.Exception
getSession
ServerSession getSession(java.lang.String name)
getSessions
java.util.Set<ServerSession> getSessions()
isStarted
boolean isStarted()
- Specified by:
isStarted
in interface MessagingComponent
getSecurityRepository
HierarchicalRepository<java.util.Set<Role>> getSecurityRepository()
getAddressSettingsRepository
HierarchicalRepository<AddressSettings> getAddressSettingsRepository()
getConnectionCount
int getConnectionCount()
getPostOffice
PostOffice getPostOffice()
getQueueFactory
QueueFactory getQueueFactory()
getResourceManager
ResourceManager getResourceManager()
getSessions
java.util.List<ServerSession> getSessions(java.lang.String connectionID)
getClusterManager
ClusterManager getClusterManager()
getNodeID
SimpleString getNodeID()
getReplicatingChannel
Channel getReplicatingChannel()
initialiseBackup
void initialiseBackup(UUID nodeID,
long currentMessageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
isInitialised
boolean isInitialised()
createQueue
Queue createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
throws java.lang.Exception
- Throws:
java.lang.Exception
deployQueue
Queue deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary)
throws java.lang.Exception
- Throws:
java.lang.Exception
destroyQueue
void destroyQueue(SimpleString queueName,
ServerSession session)
throws java.lang.Exception
- Throws:
java.lang.Exception
handleReplicateRedistribution
void handleReplicateRedistribution(SimpleString queueName,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2006 JBoss Inc. All Rights Reserved.