public static final class QueueProxy.Receiver extends QueueProxy implements ReceiverSession
Modifier and Type | Class and Description |
---|---|
static class |
QueueProxy.Receiver.Builder
Builder.
|
QueueProxy.Receiver, QueueProxy.Sender
SOMProxy.ContextProperties
SessionProxy.Listener, SessionProxy.SessionConnectVetoException
Session.ConnectionMode
PASSWORD_PROPERTY, TIMEOUT_PROPERTY, USER_PROPERTY
Modifier and Type | Method and Description |
---|---|
void |
commit()
Commits uncommitted messages.
|
protected Session |
createSession()
Creates a session.
|
static QueueProxy.Receiver.Builder |
newBuilder()
Returns a new builder.
|
long |
purge()
Purges the queue.
|
Serializable[] |
receive(int limit,
long timeout)
Receives messages.
|
void |
rollback()
Rolls back uncommitted messages.
|
protected String |
sessionMode()
Returns some session mode identifying text.
|
connect, getInfo
close, confirmTimeout, disconnect, getSOMName, isClosed
getClientName, getConnectionMode, getContext, getContextUUID, getFactory, getServerName, getServerURI, getSession, getThisLogger, hasLoginInfo, isConnected, isPrivate, isRemote, lockConnect, lockConnectInterruptibly, login, logout, sessionException, tearDown, unlockConnect
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
getConnectionMode, login, logout
@Nonnull @CheckReturnValue public static QueueProxy.Receiver.Builder newBuilder()
public void commit() throws SessionException
commit
in interface ReceiverSession
SessionException
- From session security check.public long purge() throws SessionException
purge
in interface ReceiverSession
SessionException
- From session security check.public Serializable[] receive(int limit, long timeout) throws SessionException
receive
in interface ReceiverSession
limit
- The maximum number of messages.timeout
- A time limit in millis to wait for the first message
(negative for infinite).SessionException
- From session security check.public void rollback() throws SessionException
rollback
in interface ReceiverSession
SessionException
- From session security check.protected Session createSession() throws RemoteException, SessionException
createSession
in class QueueProxy
RemoteException
- From RMI.SessionException
- When session creation fails.protected String sessionMode()
sessionMode
in class SessionProxy
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.