public static final class SOMSubscriber.Client extends SOMEndPoint.Abstract implements SOMSubscriber
SOMSubscriber.Client, SOMSubscriber.Server
SOMEndPoint.Abstract
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes.
|
Optional<TopicInfo> |
getInfo()
Gets the topic info.
|
Optional<SOMServerImpl> |
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() |
clearException, getException, setException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getException
public void close()
close
in interface SOMEndPoint
public Optional<TopicInfo> getInfo()
getInfo
in interface SOMSubscriber
public String getSOMName()
getSOMName
in interface SOMEndPoint
public Optional<SOMServerImpl> getServer()
getServer
in interface SOMEndPoint
public Optional<URI> getServerURI()
getServerURI
in interface SOMEndPoint
public boolean isClosed()
isClosed
in interface SOMEndPoint
public boolean isOpen()
isOpen
in interface SOMEndPoint
public boolean isRemote()
isRemote
in interface SOMEndPoint
public boolean isServer()
isServer
in interface SOMEndPoint
public boolean open()
open
in interface SOMEndPoint
public Serializable[] receive(int limit, long timeout)
receive
in interface SOMSubscriber
limit
- The maximum number of messages.timeout
- A time limit in millis to wait for the first message
(negative for infinite).public void tearDown()
tearDown
in interface SOMEndPoint
public String toString()
toString
in class Object
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.