public class SubscriberWrapper extends TopicServerWrapper
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the subscriber.
|
Serializable[] |
receive(int limit,
long timeout)
Receives messages.
|
getInfo, getServer, getTopicServer
closeServer, getServerName, isServerClosed, tearDownServer, toString
public void close()
@Nonnull @CheckReturnValue public Serializable[] receive(int limit, long timeout) throws ServiceClosedException
limit
- The maximum number of messages.timeout
- A time limit in millis (negative for infinite).ServiceClosedException
- When the service is closed.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.