1 package org.sapia.ubik.rmi.examples.replication; 2 3 import org.sapia.ubik.rmi.examples.Foo; 4 import org.sapia.ubik.rmi.interceptor.Interceptor; 5 import org.sapia.ubik.rmi.replication.ReplicationEvent; 6 7 import java.util.Set ; 8 9 10 18 public class ServerSideInterceptor implements Interceptor { 19 private Foo _target; 20 private Set _siblings; 21 22 25 public ServerSideInterceptor(Set siblings, Foo targetInstance) { 26 _siblings = siblings; 27 _target = targetInstance; 28 } 29 30 public void onReplicationEvent(ReplicationEvent evt) { 31 if (evt.getReplicatedCommand() instanceof ReplicatedCommandEx) { 32 System.out.println("Replicated command intercepted..."); 33 34 ReplicatedInvokerImpl inv = (ReplicatedInvokerImpl) evt.getReplicatedCommand() 35 .getReplicatedInvoker(); 36 inv.setTargetInstance(_target); 37 inv.setSiblings(_siblings); 38 } 39 } 40 } 41 | Popular Tags |