org.rvpf.service.som

Class SOMSender.Server

Object

SOMEndPoint.Abstract

SOMSender.Server

All Implemented Interfaces:

SOMEndPoint, SOMSender

Enclosing interface:

SOMSender

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

Server.

Nested Class Summary

Nested classes/interfaces inherited from interface SOMSender

SOMSender.Client, SOMSender.Server

Nested classes/interfaces inherited from interface SOMEndPoint

SOMEndPoint.Abstract

Method Summary

Modifier and Type	Method and Description
void	close() Closes.
boolean	commit() Commits uncommitted messages.
Optional<QueueInfo>	getInfo() Gets the queue info.
Optional<QueueServerImpl>	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.
boolean	rollback() Rolls back uncommitted messages
boolean	send(Serializable[] messages, boolean commit) Sends 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

commit

public boolean commit()

Commits uncommitted messages.

Specified by:

commit in interface SOMSender

Returns:

True on success.

getInfo

public Optional<QueueInfo> getInfo()

Gets the queue info.

Specified by:

getInfo in interface SOMSender

Returns:

The queue 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<QueueServerImpl> 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.

rollback

public boolean rollback()

Rolls back uncommitted messages

Specified by:

rollback in interface SOMSender

Returns:

True on success.

send

public boolean send(Serializable[] messages,
                    boolean commit)

Sends messages.

Specified by:

send in interface SOMSender

Parameters:

messages - The messages.

commit - If true, commits.

Returns:

True on success.

tearDown

public void tearDown()

Tears down.

Specified by:

tearDown in interface SOMEndPoint

toString

public String toString()

Overrides:

toString in class Object