Examples of org.springmodules.javaspaces.JavaSpaceInterceptor

org.springmodules.javaspaces.JavaSpaceInterceptor

Generic invoker for Java space-implemented methods. It allows method invocations on a given proxy interface to be transparently implemented as write/take operations of a generic entry to a JavaSpace. This is used as the terminal interceptor for a Spring AOP proxy. See the Spring implementation of local and remote EJB proxies, which illustrates the same concepts.

This class supports two modes of JavaSpace usage:

The endpoint hosts the service, and only the method to be invoked and arguments are passed around the network. This is somewhat like a SLSB approach to remoting, although there is no assumption as to where the endpoint is.

The endpoint does not necessarily host the service. The code to execute as well as the method and arguments are shipped to the node that takes from the space. This is a "runnable entry" approach. To enable this, simply set the serializableTarget property on this object to an object that can be serialized to implement the method. Typically this will be dependency injected with Spring, allowing the object to be configured. Make sure this object is serializable. Alternatively, override the serializableTarget() method to return a custom object.

This interceptor is generic. One interceptor instance can serve multiple methods. @author Rod Johnson @author Costin Leau


  public void testSuccessfulInvocations() throws Exception {


    TestBean target = new TestBean();


    JavaSpaceInterceptor si = new JavaSpaceInterceptor(template);
    ProxyFactory pf = new ProxyFactory(new Class[] { ITestBean.class });
    pf.addAdvice(new PerformanceMonitorInterceptor());
    pf.addAdvice(si);


    ITestBean proxy = (ITestBean) pf.getProxy();

    testThrowable(new RuntimeException(""));
  }


  private void testThrowable(Throwable t) throws Throwable {


    JavaSpaceInterceptor si = new JavaSpaceInterceptor(template);
    ProxyFactory pf = new ProxyFactory(new Class[] { ITestBean.class });
    pf.addAdvice(new PerformanceMonitorInterceptor());
    pf.addAdvice(si);


    ITestBean proxy = (ITestBean) pf.getProxy();

      }
    }
  }


  public void testAsynchInterceptor() throws Throwable {
    JavaSpaceInterceptor si = new JavaSpaceInterceptor(template);
    si.setSynchronous(false);
    ProxyFactory pf = new ProxyFactory(new Class[] { ITestBean.class });
    pf.addAdvice(new PerformanceMonitorInterceptor());
    pf.addAdvice(si);


    ITestBean proxy = (ITestBean) pf.getProxy();

      // can't proxy strings
    }
  }


  public void testLazyTest() throws Throwable {
    JavaSpaceInterceptor si = new JavaSpaceInterceptor(template);
    si.setSynchronous(false);
    ProxyFactory pf = new ProxyFactory(new Class[] { ITestBean.class });
    pf.addAdvice(new PerformanceMonitorInterceptor());
    pf.addAdvice(si);
    ITestBean proxy = (ITestBean) pf.getProxy();

Related Classes of org.springmodules.javaspaces.JavaSpaceInterceptor

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.