[jboss-cvs] JBossCache/tests/functional/org/jboss/cache/jmx ...

[Brian Stansberry]

  User: bstansberry
  Date: 07/05/23 01:45:45

  Modified:    tests/functional/org/jboss/cache/jmx 
                        CacheLegacyJmxWrapperTest.java
  Log:
  Add test of creation of multiplexer channel via JMX invocation
  
  Revision  Changes    Path
  1.2       +43 -0     JBossCache/tests/functional/org/jboss/cache/jmx/CacheLegacyJmxWrapperTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: CacheLegacyJmxWrapperTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/tests/functional/org/jboss/cache/jmx/CacheLegacyJmxWrapperTest.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -b -r1.1 -r1.2
  --- CacheLegacyJmxWrapperTest.java	23 May 2007 05:23:53 -0000	1.1
  +++ CacheLegacyJmxWrapperTest.java	23 May 2007 05:45:45 -0000	1.2
  @@ -29,6 +29,7 @@
   import java.util.Properties;
   
   import javax.management.MBeanServerInvocationHandler;
  +import javax.management.ObjectName;
   import javax.transaction.TransactionManager;
   
   import org.jboss.cache.Version;
  @@ -51,6 +52,7 @@
   import org.jboss.cache.loader.FileCacheLoader;
   import org.jboss.cache.loader.jdbm.JdbmCacheLoader;
   import org.jboss.cache.lock.IsolationLevel;
  +import org.jboss.cache.multiplexer.MultiplexerTestHelper;
   import org.jboss.cache.transaction.BatchModeTransactionManagerLookup;
   import org.jboss.cache.xml.XmlHelper;
   import org.jgroups.ChannelFactory;
  @@ -61,7 +63,7 @@
    * Test of the CacheLegacyJmxWrapper.
    * 
    * @author <a href="brian.stansberry at jboss.com">Brian Stansberry</a>
  - * @version $Revision: 1.1 $
  + * @version $Revision: 1.2 $
    */
   public class CacheLegacyJmxWrapperTest extends CacheJmxWrapperTestBase
   {
  @@ -230,6 +232,30 @@
         assertSame("Same ChannelFactory", cf, rc.getMuxChannelFactory());
      }
      
  +   public void testLegacyMuxChannelCreation() throws Exception
  +   {
  +      CacheLegacyJmxWrapperMBean wrapper = new CacheLegacyJmxWrapper();
  +      registerWrapper(wrapper);
  +      
  +      wrapper = (CacheLegacyJmxWrapperMBean) MBeanServerInvocationHandler.newProxyInstance(mBeanServer, mBeanName, CacheLegacyJmxWrapperMBean.class, false);
  +      wrapper.setMultiplexerStack(MultiplexerTestHelper.MUX_STACK);
  +      
  +      JChannelFactory factory = new JChannelFactory();
  +      factory.setDomain("jbc.mux.test");
  +      factory.setExposeChannels(false);
  +      factory.setMultiplexerConfig(MultiplexerTestHelper.getClusterConfigElement(getDefaultProperties()));
  +
  +      ObjectName on = new ObjectName("jgroups:service=Mux");
  +      mBeanServer.registerMBean(new org.jgroups.jmx.JChannelFactory(factory), on);
  +      
  +      wrapper.setMultiplexerService(on);
  +      
  +      wrapper.start();
  +      
  +      RuntimeConfig rc = wrapper.getConfiguration().getRuntimeConfig();
  +      assertNotNull("Channel created", rc.getChannel());
  +   }
  +   
      protected static Element getBuddyReplicationConfig() throws Exception
      {
         String xmlString = "<config><buddyReplicationEnabled>true</buddyReplicationEnabled>\n" +
  @@ -358,6 +384,23 @@
         return XmlHelper.stringToElement(xml);
      }
      
  +   protected String getDefaultProperties()
  +   {
  +      return "UDP(mcast_addr=224.0.0.36;mcast_port=55566;ip_ttl=32;" +
  +              "mcast_send_buf_size=150000;mcast_recv_buf_size=80000):" +
  +              "PING(timeout=1000;num_initial_members=2):" +
  +              "MERGE2(min_interval=5000;max_interval=10000):" +
  +              "FD_SOCK:" +
  +              "VERIFY_SUSPECT(timeout=1500):" +
  +              "pbcast.NAKACK(gc_lag=50;max_xmit_size=8192;retransmit_timeout=600,1200,2400,4800):" +
  +              "UNICAST(timeout=600,1200,2400,4800):" +
  +              "pbcast.STABLE(desired_avg_gossip=20000):" +
  +              "FRAG(frag_size=8192;down_thread=false;up_thread=false):" +
  +              "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;" +
  +              "shun=false;print_local_addr=true):" +
  +              "pbcast.STATE_TRANSFER";
  +   }
  +   
      class MockInvocationHandler implements InvocationHandler
      {