org.rvpf.som.topic

Class TopicServerImpl

Object

SessionFactoryImpl

SOMServerImpl

TopicServerImpl

All Implemented Interfaces:

Remote, SOMServer, TopicServer, SessionFactory

public final class TopicServerImpl
extends SOMServerImpl
implements TopicServer

Topic server implementation.

Nested Class Summary

Nested classes/interfaces inherited from class SOMServerImpl

SOMServerImpl.Descriptor

Field Summary

Fields inherited from class SOMServerImpl

DEFAULT_KEEP_ALIVE, DEFAULT_KEEP_ALIVE_PROPERTY, KEEP_ALIVE_PROPERTY, READ_ROLE, READ_ROLE_PROPERTY, WRITE_ROLE, WRITE_ROLE_PROPERTY

Fields inherited from interface SOMServer

BINDING_PROPERTY, DEFAULT_QUEUE_BINDING_PREFIX, DEFAULT_TOPIC_BINDING_PREFIX, NAME_PROPERTY

Constructor Summary

Constructors

Constructor and Description
TopicServerImpl(Optional<SessionSecurityContext> securityContext) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the sessions.
PublisherSession	createPublisherSession(UUID uuid, String clientName) Creates a publisher session.
PublisherWrapper	createPublisherWrapper() Creates a publisher wrapper.
SubscriberSession	createSubscriberSession(UUID uuid, String clientName) Creates a subscriber session.
SubscriberWrapper	createSubscriberWrapper() Creates a subscriber wrapper.
TopicInfo	getInfo() Gets the topic info.
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 topicProperties) Sets up this server.
void	tearDown() Tears down what has been set up.

Methods inherited from class SOMServerImpl

bind, fillRolesMap, getKeepAlive, getName, getURI, setUp, setUp, stop, toString

Methods inherited from class SessionFactoryImpl

addSession, createSecurityContext, createSession, createSession, equals, export, getConfig, getMappedRoles, getRealm, getSessionCount, getSessions, getThisLogger, hashCode, hasRolesMap, hasSecurityContext, isClosed, mapRoles, unexport

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface SOMServer

getKeepAlive, getName

Constructor Detail

TopicServerImpl

public TopicServerImpl(@Nonnull
                       Optional<SessionSecurityContext> securityContext)

Constructs an instance.

Parameters:

securityContext - The optional security context.

Method Detail

close

public void close()

Closes the sessions.

Overrides:

close in class SessionFactoryImpl

createPublisherSession

public PublisherSession createPublisherSession(UUID uuid,
                                               String clientName)
                                        throws SessionException

Creates a publisher session.

Specified by:

createPublisherSession in interface TopicServer

Parameters:

uuid - A UUID used to locate the RMI client instance.

clientName - A descriptive name for the client.

Returns:

The publisher session.

Throws:

SessionException - When the session creation fails.

createPublisherWrapper

@Nonnull
 @CheckReturnValue
public PublisherWrapper createPublisherWrapper()

Creates a publisher wrapper.

Returns:

The publisher wrapper.

createSubscriberSession

public SubscriberSession createSubscriberSession(UUID uuid,
                                                 String clientName)
                                          throws SessionException

Creates a subscriber session.

Specified by:

createSubscriberSession in interface TopicServer

Parameters:

uuid - A UUID used to locate the RMI client instance.

clientName - A descriptive name for the client.

Returns:

The subscriber session.

Throws:

SessionException - When the session creation fails.

createSubscriberWrapper

@Nonnull
 @CheckReturnValue
public SubscriberWrapper createSubscriberWrapper()

Creates a subscriber wrapper.

Returns:

The subscriber wrapper.

getInfo

public TopicInfo getInfo()

Gets the topic info.

Specified by:

getInfo in interface TopicServer

Returns:

The topic info.

removeSession

public boolean removeSession(SessionImpl session)

Removes a session from the set.

Specified by:

removeSession in interface SessionFactory

Overrides:

removeSession in class SOMServerImpl

Parameters:

session - The session.

Returns:

True if the session was in the set.

setUp

public boolean setUp(Config config,
                     KeyedGroups topicProperties)

Sets up this server.

Specified by:

setUp in class SOMServerImpl

Parameters:

config - The configuration.

topicProperties - The queue properties.

Returns:

True on success.

tearDown

public void tearDown()

Tears down what has been set up.

Overrides:

tearDown in class SOMServerImpl

newSession

protected Session newSession(Session.ConnectionMode connectionMode,
                             Optional<RMIClientSocketFactory> clientSocketFactory,
                             Optional<RMIServerSocketFactory> serverSocketFactory,
                             Object reference)

Returns a new session

Specified by:

newSession in class SessionFactoryImpl

Parameters:

connectionMode - The connection mode.

clientSocketFactory - The optional client socket factory.

serverSocketFactory - The optional server socket factory.

reference - A reference object.

Returns:

The session.