org.rvpf.service.som

Interface SOMSubscriber

All Superinterfaces:

SOMEndPoint

All Known Implementing Classes:

SOMSubscriber.Client, SOMSubscriber.Server

public interface SOMSubscriber
extends SOMEndPoint

SOM subscriber.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	SOMSubscriber.Client Client.
static class	SOMSubscriber.Server Server.

Nested classes/interfaces inherited from interface SOMEndPoint

SOMEndPoint.Abstract

Method Summary

Modifier and Type	Method and Description
Optional<TopicInfo>	getInfo() Gets the topic info.
Serializable[]	receive(int limit, long timeout) Receives messages.

Methods inherited from interface SOMEndPoint

close, getException, getServer, getServerURI, getSOMName, isClosed, isOpen, isRemote, isServer, open, tearDown

Method Detail

getInfo

@Nonnull
 @CheckReturnValue
Optional<TopicInfo> getInfo()

Gets the topic info.

Returns:

The topic info (empty on failure).

receive

@Nullable
 @CheckReturnValue
Serializable[] receive(int limit,
                                                      long timeout)

Receives messages.

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).