org.rvpf.som.queue

Class SenderWrapper

Object

SOMServerWrapper

QueueServerWrapper

SenderWrapper

public class SenderWrapper
extends QueueServerWrapper

Sender wrapper.

Method Summary

Modifier and Type	Method and Description
void	close() Closes.
void	commit() Commits uncommitted messages.
void	rollback() Rolls back uncommitted messages.
void	send(Serializable[] messages, boolean commit) Sends messages.

Methods inherited from class QueueServerWrapper

getInfo, getQueueServer, getServer, isDirty

Methods inherited from class SOMServerWrapper

closeServer, getServerName, isServerClosed, tearDownServer, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

close

public void close()

Closes.

commit

public void commit()
            throws ServiceClosedException

Commits uncommitted messages.

Throws:

ServiceClosedException - When the service is closed.

rollback

public void rollback()
              throws ServiceClosedException

Rolls back uncommitted messages.

Throws:

ServiceClosedException - When the service is closed.

send

public void send(@Nonnull
                 Serializable[] messages,
                 boolean commit)
          throws ServiceClosedException

Sends messages.

Parameters:

messages - The messages.

commit - If true, commits.

Throws:

ServiceClosedException - When the service is closed.