[Join-cvs] join1/src/test/org/figure8/join/services/remoting/services BeansHelperTest.java, 1.3, 1.4

[Laurent B. <lbr...@us...>]

Update of /cvsroot/join/join1/src/test/org/figure8/join/services/remoting/services
In directory sc8-pr-cvs6.sourceforge.net:/tmp/cvs-serv8416/services/remoting/services

Modified Files:
	BeansHelperTest.java 
Log Message:
Add feature for remote interaction with resources and their versions

Index: BeansHelperTest.java
===================================================================
RCS file: /cvsroot/join/join1/src/test/org/figure8/join/services/remoting/services/BeansHelperTest.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** BeansHelperTest.java	6 Feb 2007 21:45:48 -0000	1.3
--- BeansHelperTest.java	3 Feb 2008 22:57:11 -0000	1.4
***************
*** 1,4 ****
  /**
!  * Copyright 2005-2006 the original author or authors.
   *
   * Licensed under the Gnu General Pubic License, Version 2.0 (the
--- 1,4 ----
  /**
!  * Copyright 2005-2008 the original author or authors.
   *
   * Licensed under the Gnu General Pubic License, Version 2.0 (the
***************
*** 17,20 ****
--- 17,21 ----
  import org.figure8.join.core.InvalidParameterException;
  import org.figure8.join.core.messaging.JMSConsumerBeanInfo;
+ import org.figure8.join.core.messaging.JMSConsumerBeanParameterInfo;
  import org.figure8.join.businessobjects.commons.Status;
  import org.figure8.join.businessobjects.commons.Release;
***************
*** 27,30 ****
--- 28,32 ----
  import org.figure8.join.services.remoting.beans.RemoteJMSConsumerBeanInfo;
  import org.figure8.join.services.remoting.beans.RemoteMailingList;
+ import org.figure8.join.services.remoting.beans.RemoteParameter;
  
  import junit.framework.Test;
***************
*** 111,116 ****
     }
  
     /** Test the getRemoteObject() method for JMSConsumerBeanInfos. */
!    public void testGetRemoteJMSConsumberBeanInfo(){
        // Create a new JMSConsumerBeanInfo.
        JMSConsumerBeanInfo info = null;
--- 113,143 ----
     }
  
+    /** Test the getLocalObject() method for JMSConsumerBeanInfos. */
+    public void testGetLocalJMSConsumerBeanInfo(){
+       // Create a new RemoteConsumerBeanInfo.
+       RemoteJMSConsumerBeanInfo info = new RemoteJMSConsumerBeanInfo("name", "selector",
+               "destination", "org.figure8.join.core.messaging.EchoJMSConsumerBean", true, false);
+ 
+       info.addConsumerParameterInfo(new RemoteParameter("param1", "value1"));
+       info.addConsumerParameterInfo(new RemoteParameter("param2", "value2"));
+       // Retrieve and check consumer info.
+       JMSConsumerBeanInfo local = null;
+       try {local = BeansHelper.getLocalObject(info);}
+       catch (InvalidParameterException e){
+          fail("Should not have thrown exception when creating consumer info");
+       }
+       assertNotNull("Get a JMSConsumerBeanInfo", local);
+       assertEquals("Get a correct JMSConsumerBeanInfo", "name", local.getName());
+       assertEquals("Get a correct JMSConsumerBeanInfo", "selector", local.getSelector());
+       assertEquals("Get a correct JMSConsumerBeanInfo", "destination", local.getDestination());
+       assertEquals("Get a correct JMSConsumerBeanInfo",
+               "org.figure8.join.core.messaging.EchoJMSConsumerBean", local.getConsumerBeanClass());
+       assertEquals("Get a correct JMSConsumerBeanInfo", true, local.isActive());
+       assertEquals("Get a correct JMSConsumerBeanInfo", false, local.isThreadSafe());
+       assertEquals("Get a correct JMSConsumerBeanInfo", 2, local.getConsumerParameterInfos().size());
+    }
+ 
     /** Test the getRemoteObject() method for JMSConsumerBeanInfos. */
!    public void testGetRemoteJMSConsumerBeanInfo(){
        // Create a new JMSConsumerBeanInfo.
        JMSConsumerBeanInfo info = null;
***************
*** 121,134 ****
        info.setActive(true);
        info.setThreadSafe(false);
        // Retrieve and check consumer info.
        RemoteJMSConsumerBeanInfo remote = BeansHelper.getRemoteObject(info);
        assertNotNull("Get a RemoteJMSConsumerBeanInfo", remote);
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo", "name", remote.getName());
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo", "selector", remote.getSelector());
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo", "destination", remote.getDestination());
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo",
                "org.figure8.join.core.messaging.EchoJMSConsumerBean", remote.getConsumerBeanClass());
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo", true, remote.isActive());
!       assertEquals("Get a corresct RemoteJMSConsumerBeanInfo", false, remote.isThreadSafe());
     }
  }
--- 148,164 ----
        info.setActive(true);
        info.setThreadSafe(false);
+       info.addConsumerParameterInfo(new JMSConsumerBeanParameterInfo("param1", "value1"));
+       info.addConsumerParameterInfo(new JMSConsumerBeanParameterInfo("param2", "value2"));
        // Retrieve and check consumer info.
        RemoteJMSConsumerBeanInfo remote = BeansHelper.getRemoteObject(info);
        assertNotNull("Get a RemoteJMSConsumerBeanInfo", remote);
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", "name", remote.getName());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", "selector", remote.getSelector());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", "destination", remote.getDestination());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo",
                "org.figure8.join.core.messaging.EchoJMSConsumerBean", remote.getConsumerBeanClass());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", true, remote.isActive());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", false, remote.isThreadSafe());
!       assertEquals("Get a correct RemoteJMSConsumerBeanInfo", 2, remote.getConsumerParameterInfos().size());
     }
  }