public final class QueueServerImpl extends SOMServerImpl implements QueueServer
SOMServerImpl.Descriptor
Modifier and Type | Field and Description |
---|---|
static String |
BACKUP_ALL_PROPERTY
True will backup messages on all queues.
|
static String |
DEFAULT_ROOT
Default queue root directory.
|
static String |
LOCK_DISABLED_PROPERTY
The lock disabled property.
|
static String |
MEMORY_PROPERTY
Memory property.
|
static String |
MERGE_LIMIT_ALL_PROPERTY
Merge limit for all queues.
|
static String |
MERGE_SPLIT_ALL_PROPERTY
Merge split for all queues.
|
static String |
ROOT_ALL_PROPERTY
The root directory for the SOM queues.
|
DEFAULT_KEEP_ALIVE, DEFAULT_KEEP_ALIVE_PROPERTY, KEEP_ALIVE_PROPERTY, READ_ROLE, READ_ROLE_PROPERTY, WRITE_ROLE, WRITE_ROLE_PROPERTY
BINDING_PROPERTY, DEFAULT_QUEUE_BINDING_PREFIX, DEFAULT_TOPIC_BINDING_PREFIX, NAME_PROPERTY
Constructor and Description |
---|
QueueServerImpl(Optional<SessionSecurityContext> securityContext)
Constructs an instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the sessions.
|
ReceiverSession |
createReceiverSession(UUID uuid,
String clientName)
Creates a receiver session.
|
ReceiverWrapper |
createReceiverWrapper()
Creates a receiver wrapper.
|
SenderSession |
createSenderSession(UUID uuid,
String clientName)
Creates a sender session.
|
SenderWrapper |
createSenderWrapper()
Creates a sender wrapper.
|
QueueInfo |
getInfo()
Gets the queue info.
|
Queue |
getQueue()
Gets the queue.
|
protected Session |
newSession(Session.ConnectionMode connectionMode,
Optional<RMIClientSocketFactory> clientSocketFactory,
Optional<RMIServerSocketFactory> serverSocketFactory,
Object reference)
Returns a new session
|
boolean |
removeSession(SessionImpl session)
Removes a session from the set.
|
boolean |
setUp(Config config,
KeyedGroups queueProperties)
Sets up this server.
|
void |
tearDown()
Tears down what has been set up.
|
bind, fillRolesMap, getKeepAlive, getName, getURI, setUp, setUp, stop, toString
addSession, createSecurityContext, createSession, createSession, equals, export, getConfig, getMappedRoles, getRealm, getSessionCount, getSessions, getThisLogger, hashCode, hasRolesMap, hasSecurityContext, isClosed, mapRoles, unexport
getKeepAlive, getName
public static final String BACKUP_ALL_PROPERTY
public static final String DEFAULT_ROOT
public static final String LOCK_DISABLED_PROPERTY
public static final String MEMORY_PROPERTY
public static final String MERGE_LIMIT_ALL_PROPERTY
public static final String MERGE_SPLIT_ALL_PROPERTY
public static final String ROOT_ALL_PROPERTY
public QueueServerImpl(@Nonnull Optional<SessionSecurityContext> securityContext)
securityContext
- The optional security context.public void close()
close
in class SessionFactoryImpl
public ReceiverSession createReceiverSession(UUID uuid, String clientName) throws SessionException
createReceiverSession
in interface QueueServer
uuid
- A UUID used to locate the RMI client instance.clientName
- A descriptive name for the client.SessionException
- When the session creation fails.@Nonnull @CheckReturnValue public ReceiverWrapper createReceiverWrapper() throws ReceiverActiveException
ReceiverActiveException
- When a receiver is already active.public SenderSession createSenderSession(UUID uuid, String clientName) throws SessionException
createSenderSession
in interface QueueServer
uuid
- A UUID used to locate the RMI client instance.clientName
- A descriptive name for the client.SessionException
- When the session creation fails.@Nonnull @CheckReturnValue public SenderWrapper createSenderWrapper()
public QueueInfo getInfo()
getInfo
in interface QueueServer
@Nonnull @CheckReturnValue public Queue getQueue()
public boolean removeSession(SessionImpl session)
removeSession
in interface SessionFactory
removeSession
in class SOMServerImpl
session
- The session.public boolean setUp(Config config, KeyedGroups queueProperties)
setUp
in class SOMServerImpl
config
- The configuration.queueProperties
- The queue properties.public void tearDown()
tearDown
in class SOMServerImpl
protected Session newSession(Session.ConnectionMode connectionMode, Optional<RMIClientSocketFactory> clientSocketFactory, Optional<RMIServerSocketFactory> serverSocketFactory, Object reference) throws ReceiverActiveException
newSession
in class SessionFactoryImpl
connectionMode
- The connection mode.clientSocketFactory
- The optional client socket factory.serverSocketFactory
- The optional server socket factory.reference
- A reference object.ReceiverActiveException
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.