testconnector.java

java开源的企业总线.xmlBlaster

package org.xmlBlaster.test.jmx;

import java.io.IOException;
import junit.framework.*;

import java.util.logging.Logger;
import java.util.logging.Level;
import org.xmlBlaster.util.Global;

import org.xmlBlaster.util.admin.extern.SerializeHelper;
import org.xmlBlaster.util.admin.extern.MethodInvocation;
import org.xmlBlaster.client.I_XmlBlasterAccess;
import org.xmlBlaster.client.qos.ConnectQos;
import org.xmlBlaster.util.qos.address.Address;
import org.xmlBlaster.client.qos.PublishReturnQos;
import org.xmlBlaster.client.qos.*;

import org.xmlBlaster.client.key.*;


import org.xmlBlaster.client.I_Callback;

import org.xmlBlaster.util.MsgUnit;

import org.xmlBlaster.util.XmlBlasterException;

import java.util.Properties;

//import org.xmlBlaster.test.Util;

public class TestConnector  extends TestCase implements I_Callback {
  private final int serverPort = 3424;
  private final static String ME = "TestConnector";
  private Global glob = null;
   private static Logger log = Logger.getLogger(TestConnector.class.getName());
  private I_XmlBlasterAccess returnCon;
  private I_XmlBlasterAccess invokeCon;

  private MsgUnit msg = null;
  private static String port = "3424";

  SerializeHelper sh = null;
  MethodInvocation mi = null;

  public TestConnector(String testName)
   {
       super(testName);
   }


   protected void setUp()
   {
     if (this.glob == null) this.glob = Global.instance();

     log.info("setUp of TestConnector...");
     //connect to embedded xmlBlaster

    Properties prop = new Properties();
    prop.setProperty("bootstrapPort",port);
    prop.setProperty("bootstrapHostname","localhost");

    glob.init(prop);

    invokeCon = glob.getXmlBlasterAccess();
    returnCon = glob.getXmlBlasterAccess();

//    log.info("Connecting to embedded xmlBlaster on port "+ port +" Adresse " + addr.getAddress());
    try {
      ConnectQos qos = new ConnectQos(glob, "InternalConnector", "connector");
      returnCon.connect(qos, this);
    }
    catch (XmlBlasterException ex) {
      assertTrue("Error when connecting to xmlBlaster " + ex.toString(), false);
      log.severe("Error when connecting to xmlBlaster " + ex.toString());
    }
    SubscribeKey subKey = new SubscribeKey(this.glob, "xmlBlasterMBeans_Return");

    SubscribeQos sQos = new SubscribeQos(this.glob);
    sQos.setWantLocal(false);
    try {
      returnCon.subscribe(subKey, sQos);
    }
    catch (XmlBlasterException ex) {
      assertTrue("Error when subscribing to xmlBlaster " + ex.toString(), false);
      log.severe("Error when subscribing to xmlBlaster " + ex.toString());
    }
     sh = new SerializeHelper(glob);

     if (invokeCon.isConnected() && returnCon.isConnected()) {log.info("connection establisheld");}
     else log.warning("Couldnt connect to server on port " + port);
   }


   /**
    * Method is used by TestRunner to load these tests
    */
   public static Test suite() {
       TestSuite suite= new TestSuite();
       suite.addTest(new TestConnector("testConnector"));
       return suite;
   }

   /**
    * TEST:
    * <p />
    */
   public void testConnector() {
     try {
       log.info("Creating TestMessage");
       mi = new MethodInvocation();
       mi.setMethodName("getDefaultDomain");
       log.info("new MethodInvocation build " + mi.getMethodName());
       PublishReturnQos rqos = invokeCon.publish(new MsgUnit("<key oid='xmlBlasterMBeans_Invoke'/>",sh.serializeObject(mi),"<qos/>"));
       log.info("Publish test Message to jmx-topic..");
       }
    catch (XmlBlasterException ex) {
      ex.printStackTrace();
    }
    catch (IOException ex) {
      log.severe("Error when creating methodInvocation " + ex.toString());
      ex.printStackTrace();
    }

   }


   /**
    * This is the callback method invoked from xmlBlaster
    * delivering us a new asynchronous message.
    * @see org.xmlBlaster.client.I_Callback#update(String, UpdateKey, byte[], UpdateQos)
    */
   public String update(String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
   {
      log.info("Receiving update of a message, checking ...");
      MethodInvocation mi = null;
      try {
        mi = (MethodInvocation) sh.deserializeObject(content);
      }
      catch (IOException ex) {
        log.severe("Error when deserializing object");
      }
      Object obj = mi.getReturnValue();
      log.info("Received Object: " + obj);
      if (obj.toString().length()>0) log.info("Success... Received Domainname: " + obj);
      else {
        log.severe("Error when receiving returning object...");
        assertTrue("Error when receiving returning object...", false);
      }
      return "";
   }

}