org.rvpf.som.topic

Class SubscriberWrapper

Object

SOMServerWrapper

TopicServerWrapper

SubscriberWrapper

public class SubscriberWrapper
extends TopicServerWrapper

Subscriber wrapper.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the subscriber.
Serializable[]	receive(int limit, long timeout) Receives messages.

Methods inherited from class TopicServerWrapper

getInfo, getServer, getTopicServer

Methods inherited from class SOMServerWrapper

closeServer, getServerName, isServerClosed, tearDownServer, toString

Methods inherited from class Object

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

Method Detail

close

public void close()

Closes the subscriber.

receive

@Nonnull
 @CheckReturnValue
public Serializable[] receive(int limit,
                                                            long timeout)
                                                     throws ServiceClosedException

Receives messages.

Parameters:

limit - The maximum number of messages.

timeout - A time limit in millis (negative for infinite).

Returns:

The messages.

Throws:

ServiceClosedException - When the service is closed.