public static final class QueueProxy.Sender extends QueueProxy implements SenderSession
Modifier and Type | Class and Description |
---|---|
static class |
QueueProxy.Sender.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.Sender.Builder |
newBuilder()
Returns a new builder.
|
void |
rollback()
Rolls back uncommitted messages.
|
void |
send(Serializable[] messages,
boolean commit)
Sends 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.Sender.Builder newBuilder()
public void commit() throws SessionException
commit
in interface SenderSession
SessionException
- From session security check.public void rollback() throws SessionException
rollback
in interface SenderSession
SessionException
- From session security check.public void send(@Nonnull Serializable[] messages, boolean commit) throws SessionException
send
in interface SenderSession
messages
- The messages.commit
- If true, commits.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.