public static final class SOMReceiver.Client extends SOMEndPoint.Abstract implements SOMReceiver
SOMReceiver.Client, SOMReceiver.Server
SOMEndPoint.Abstract
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes.
|
boolean |
commit()
Commits uncommitted messages.
|
Optional<QueueInfo> |
getInfo()
Gets the queue 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.
|
long |
purge()
Purges the queue.
|
Serializable[] |
receive(int limit,
long timeout)
Receives messages.
|
boolean |
rollback()
Rolls back uncommitted 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 boolean commit()
commit
in interface SOMReceiver
public Optional<QueueInfo> getInfo()
getInfo
in interface SOMReceiver
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 long purge()
purge
in interface SOMReceiver
public Serializable[] receive(int limit, long timeout)
receive
in interface SOMReceiver
limit
- The maximum number of messages.timeout
- A time limit in millis to wait for the first message
(negative for infinite).public boolean rollback()
rollback
in interface SOMReceiver
public void tearDown()
tearDown
in interface SOMEndPoint
public String toString()
toString
in class Object
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.