org.rvpf.service.som

Class SOMSubscriber.Server

Object

SOMEndPoint.Abstract

SOMSubscriber.Server

All Implemented Interfaces:

SOMEndPoint, SOMSubscriber

Enclosing interface:

SOMSubscriber

public static final class SOMSubscriber.Server
extends SOMEndPoint.Abstract
implements SOMSubscriber

Server.

Nested Class Summary

Nested classes/interfaces inherited from interface SOMSubscriber

SOMSubscriber.Client, SOMSubscriber.Server

Nested classes/interfaces inherited from interface SOMEndPoint

SOMEndPoint.Abstract

Method Summary

Modifier and Type	Method and Description
void	close() Closes.
Optional<TopicInfo>	getInfo() Gets the topic info.
Optional<TopicServerImpl>	getServer() Gets the server.
Optional<URI>	getServerURI() Gets the server URI.
String	getSOMName() Gets the SOM name.
boolean	isClosed() Asks if closed.
boolean	isOpen() Asks if open.
boolean	isRemote() Asks if remote.
boolean	isServer() Asks if server.
boolean	open() Opens.
Serializable[]	receive(int limit, long timeout) Receives messages.
void	tearDown() Tears down.
String	toString()

Methods inherited from class SOMEndPoint.Abstract

clearException, getException, setException

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface SOMEndPoint

getException

Method Detail

close

public void close()

Closes.

Specified by:

close in interface SOMEndPoint

getInfo

public Optional<TopicInfo> getInfo()

Gets the topic info.

Specified by:

getInfo in interface SOMSubscriber

Returns:

The topic info (empty on failure).

getSOMName

public String getSOMName()

Gets the SOM name.

Specified by:

getSOMName in interface SOMEndPoint

Returns:

The SOM name.

getServer

public Optional<TopicServerImpl> getServer()

Gets the server.

Specified by:

getServer in interface SOMEndPoint

Returns:

The server implementation (empty when client).

getServerURI

public Optional<URI> getServerURI()

Gets the server URI.

Specified by:

getServerURI in interface SOMEndPoint

Returns:

The server URI (empty when server).

isClosed

public boolean isClosed()

Asks if closed.

Specified by:

isClosed in interface SOMEndPoint

Returns:

True if closed.

isOpen

public boolean isOpen()

Asks if open.

Specified by:

isOpen in interface SOMEndPoint

Returns:

True if open.

isRemote

public boolean isRemote()

Asks if remote.

Specified by:

isRemote in interface SOMEndPoint

Returns:

True if remote.

isServer

public boolean isServer()

Asks if server.

Specified by:

isServer in interface SOMEndPoint

Returns:

True if server.

open

public boolean open()

Opens.

Specified by:

open in interface SOMEndPoint

Returns:

True on success.

receive

public Serializable[] receive(int limit,
                              long timeout)

Receives messages.

Specified by:

receive in interface SOMSubscriber

Parameters:

limit - The maximum number of messages.

timeout - A time limit in millis to wait for the first message (negative for infinite).

Returns:

The messages (null on failure).

tearDown

public void tearDown()

Tears down.

Specified by:

tearDown in interface SOMEndPoint

toString

public String toString()

Overrides:

toString in class Object