org.prevayler.implementation.replication
Class ClientPublisher

java.lang.Object
  org.prevayler.implementation.replication.ClientPublisher

All Implemented Interfaces:

TransactionPublisher

public class ClientPublisher
extends Object
implements TransactionPublisher

Reserved for future implementation.

Constructor Summary

ClientPublisher(OldNetworkImpl network, String serverIpAddress, int serverPort)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientPublisher

public ClientPublisher(OldNetworkImpl network,
                       String serverIpAddress,
                       int serverPort)
                throws IOException

Throws:

IOException

Method Detail

subscribe

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

Description copied from interface: TransactionPublisher

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

Specified by:

subscribe in interface TransactionPublisher

Throws:

IOException

ClassNotFoundException

cancelSubscription

public void cancelSubscription(TransactionSubscriber subscriber)

Description copied from interface: TransactionPublisher

Stops publishing future transactions to the given subscriber.

Specified by:

cancelSubscription in interface TransactionPublisher

publish

public void publish(Capsule capsule)

Description copied from interface: TransactionPublisher

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.

Specified by:

publish in interface TransactionPublisher

clock

public Clock clock()

Description copied from interface: TransactionPublisher

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

Specified by:

clock in interface TransactionPublisher

close

public void close()
           throws IOException

Description copied from interface: TransactionPublisher

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

Specified by:

close in interface TransactionPublisher

Throws:

IOException