KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jfox > ejb > connector > ClusterableEJBContainerImpl


1 /* JFox, the OpenSource J2EE Application Server
2  *
3  * Distributable under GNU LGPL license by gun.org
4  * more details please visit http://www.huihoo.org/jfox
5  */
6
7 package org.jfox.ejb.connector;
8
9 import org.jfox.ejb.Bucket;
10 import org.jfox.ejb.EJBObjectId;
11 import org.jfox.ioc.connector.ClusterableContainer;
12 import org.jfox.ioc.connector.Invocation;
13
14 /**
15  * @author <a HREF="mailto:young_yy@hotmail.com">Young Yang</a>
16  */
17
18 public class ClusterableEJBContainerImpl extends EJBContainerImpl implements ClusterableContainer{
19
20     public ClusterableEJBContainerImpl() {
21
22     }
23
24     /**
25      * 同步其它集群节点复制过来的对象
26      * 将该对象缓存在本地的缓存池中
27      * @param invocation
28      */
29     public void syncInvocation(Invocation invocation) {
30         EJBObjectId ejbObjectId = (EJBObjectId) invocation.getObjectId();
31         // Home 方法调用，不用同步
32 if(ejbObjectId.isHome()){
33             return;
34         }
35         logger.debug("syncInvocation " + ejbObjectId);
36         String JavaDoc ejbName = ejbObjectId.getEjbName();
37         Bucket bucket = getBucket(ejbName);
38         bucket.syncBean((EJBInvocation)invocation);
39     }
40
41     public static void main(String JavaDoc[] args) {
42
43     }
44 }
45
Popular Tags