Examples of EndpointService

com.francetelecom.m2m.gateway.service.machine.zcl.element.EndPointService
@author Fabrice Blache
org.jboss.test.ws.jaxws.samples.webserviceref.EndpointService
This class was generated by the JAXWS SI. JAX-WS RI 2.0-b26-ea3 Generated source version: 2.0
org.mule.module.management.mbean.EndpointService
The EndpointServiceMBean allows you to check the confiugration of an endpoint and conect/disconnect endpoints manually.

Examples of com.francetelecom.m2m.gateway.service.machine.zcl.element.EndPointService

    }
  }


  protected void initService() {
    for (Enumeration e = pumps.elements(); e.hasMoreElements();) {
      EndPointService pumpEndpointService = (EndPointService) e
          .nextElement();
      openPump(pumpEndpointService);
    }
  }

View Full Code Here

Examples of com.francetelecom.m2m.gateway.service.machine.zcl.element.EndPointService


    // pumps
    List pumps = fireApplication.getPumps();
    JSONArray pumpsArray = new JSONArray();
    for (Iterator it = pumps.iterator(); it.hasNext();) {
      EndPointService es = (EndPointService) it.next();
      String name = es.getName();
      String friendlyName = getDeviceFriendlyNameId(es);
      name = name + " " + friendlyName;


      // remove first # from friendlyname
      friendlyName = friendlyName.replaceAll("#", "");


      String id = PUMP_PREFIX_ID + friendlyName;
      Map properties = new HashMap();
      properties.put(ID_PROP, id);
      properties.put(NAME_PROP, name);
      properties.put(TECHNO_PROP, ZIGBEE_TECHNO);
      properties.put(IMG_PROP, PUMP_IMG);
      JSONObject pumpJs = new JSONObject(properties);
      pumpsArray.add(pumpJs);
    }
    
    // GreenNet switches is also viewed as a pump (i.e. actuator)
    List greenNetSwitches = fireApplication.getGreenNetSwitches();
    for(Iterator it = greenNetSwitches.iterator(); it.hasNext();) {
      Device greenNetSwitch = (Device) it.next();
      String id = ((Actuator)greenNetSwitch).getNode().getIdentifier();
      String name = "Air extractor";
      Map properties = new HashMap();
      properties.put(ID_PROP, id);
      properties.put(NAME_PROP, name);
      properties.put(TECHNO_PROP, GREENNET_TECHNO);
      properties.put(IMG_PROP, GREENNET_AIR_EJECTOR_IMG);
      JSONObject pumpJs = new JSONObject(properties);
      pumpsArray.add(pumpJs);
    }
    devices.put(PUMPS_PROP, pumpsArray);


    // ias zones
    List zones = fireApplication.getZoneDevices();
    JSONArray zonesArray = new JSONArray();
    for (Iterator it = zones.iterator(); it.hasNext();) {
      EndPointService es = (EndPointService) it.next();
      String name = es.getName();
      String friendlyName = getDeviceFriendlyNameId(es);
      name = name + " " + friendlyName;


      // remove first # from friendlyname
      friendlyName = friendlyName.replaceAll("#", "");
      String id = IAS_ZONES_PREFIX_ID + friendlyName;
      Map properties = new HashMap();
      properties.put(ID_PROP, id);
      properties.put(NAME_PROP, name);
      properties.put(TECHNO_PROP, ZIGBEE_TECHNO);
      properties.put(IMG_PROP, SMOKE_DETECTOR_IMG);
      JSONObject zoneJs = new JSONObject(properties);
      zonesArray.add(zoneJs);
    }
    devices.put(IAS_ZONES_PROP, zonesArray);


    // warning devices
    List warnings = fireApplication.getWarningDevices();
    JSONArray warningArray = new JSONArray();
    for (Iterator it = warnings.iterator(); it.hasNext();) {
      EndPointService es = (EndPointService) it.next();
      String name = es.getName();
      String friendlyName = getDeviceFriendlyNameId(es);
      name = name + " " + friendlyName;


      // remove first # from friendlyname
      friendlyName = friendlyName.replaceAll("#", "");

View Full Code Here

Examples of org.jboss.test.ws.jaxws.samples.webserviceref.EndpointService

   /**
    * Customize service-class-name, service-qname
    */
   public String testService1(String reqStr) throws Exception
   {
      EndpointService service = (EndpointService)iniCtx.lookup("java:comp/env/Service1");
      Endpoint port = service.getEndpointPort();
      return port.echo(reqStr);
   }

View Full Code Here

Examples of org.jboss.test.ws.jaxws.samples.webserviceref.EndpointService

   public String testService3(String reqStr) throws Exception
   {
      Endpoint port = ((EndpointService)service3).getEndpointPort();
      String resStr1 = port.echo(reqStr);
      
      EndpointService service = (EndpointService)iniCtx.lookup("java:comp/env/Service3");
      port = service.getEndpointPort();
      
      String resStr2 = port.echo(reqStr);
      
      return resStr1 + resStr2; 
   }

View Full Code Here

Examples of org.jboss.test.ws.jaxws.samples.webserviceref.EndpointService

   {
      Endpoint port = service4.getEndpointPort();
      String resStr1 = port.echo(reqStr);
      //verifyConfig((ConfigProvider)port);
      
      EndpointService service = (EndpointService)iniCtx.lookup("java:comp/env/Service4");
      port = service.getEndpointPort();
      //verifyConfig((ConfigProvider)port);
      
      String resStr2 = port.echo(reqStr);
      
      return resStr1 + resStr2;

View Full Code Here

Examples of org.mule.module.management.mbean.EndpointService

        {
            if (connector instanceof AbstractConnector)
            {
                for (MessageReceiver messageReceiver : ((AbstractConnector) connector).getReceivers().values())
                {
                    EndpointServiceMBean service = new EndpointService(messageReceiver);


                    String fullName = buildFullyQualifiedEndpointName(service, connector);
                    if (logger.isInfoEnabled())
                    {
                        logger.info("Attempting to register service with name: " + fullName);

View Full Code Here

Examples of org.mule.module.management.mbean.EndpointService

            {
                for (MessageReceiver messageReceiver : ((AbstractConnector) connector).getReceivers().values())
                {
                    if (muleContext.equals(messageReceiver.getFlowConstruct().getMuleContext()))
                    {
                        EndpointServiceMBean service = new EndpointService(messageReceiver);


                        String fullName = buildFullyQualifiedEndpointName(service, connector);
                        if (logger.isInfoEnabled())
                        {
                            logger.info("Attempting to register service with name: " + fullName);

View Full Code Here

TOP

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.