org.prevayler.implementation.publishing
Interface TransactionPublisher

All Known Implementing Classes:

AbstractPublisher, CentralPublisher, ClientPublisher

public interface TransactionPublisher

Method Summary

void	cancelSubscription(TransactionSubscriber subscriber) Stops publishing future transactions to the given subscriber.
Clock	clock() Returns a Clock which is consistent with the Transaction publishing time.
void	close() Closes any files or other system resources opened by this TransactionPublisher.
void	publish(Capsule capsule) Publishes transaction to the subscribers synchronously.
void	subscribe(TransactionSubscriber subscriber, long initialTransaction) Updates the given subscriber with all transactions published since initialTransaction, returns and continues publishing all future transactions to him.

Method Detail

subscribe

void subscribe(TransactionSubscriber subscriber,
               long initialTransaction)
               throws IOException,
                      ClassNotFoundException

Updates the given subscriber with all transactions published since initialTransaction, returns and continues publishing all future transactions to him.

Throws:

IOException

ClassNotFoundException

cancelSubscription

void cancelSubscription(TransactionSubscriber subscriber)

Stops publishing future transactions to the given subscriber.

publish

void publish(Capsule capsule)

Publishes transaction to the subscribers synchronously. This method will only return after all subscribers have received transaction. Note that no guarantee can be made as to wether the subscribers have actually executed it.

clock

Clock clock()

Returns a Clock which is consistent with the Transaction publishing time.

close

void close()
           throws IOException

Closes any files or other system resources opened by this TransactionPublisher.

Throws:

IOException