Examples of ch.ethz.iks.r_osgi.messages.RemoteEventMessage

        m.setException(t);
        return m;
      }
    }
    case RemoteOSGiMessage.REMOTE_EVENT: {
      final RemoteEventMessage eventMsg = (RemoteEventMessage) msg;
      final Dictionary properties = eventMsg.getProperties();


      // transform the event timestamps
      final Long remoteTs;
      if ((remoteTs = (Long) properties.get(EventConstants.TIMESTAMP)) != null) {
        properties.put(EventConstants.TIMESTAMP, getOffset().transform(
            remoteTs));
      }


      final Event event = new Event(eventMsg.getTopic(), properties);


      // and deliver the event to the local framework
      if (RemoteOSGiServiceImpl.eventAdminTracker.getTrackingCount() > 0) {
        ((EventAdmin) RemoteOSGiServiceImpl.eventAdminTracker
            .getService()).postEvent(event);

     * @param event
     *            the event.
     */
    public void handleEvent(final Event event) {
      try {
        final RemoteEventMessage msg = new RemoteEventMessage();
        msg.setTopic(event.getTopic());
        final String[] propertyNames = event.getPropertyNames();
        final Dictionary props = new Hashtable();
        for (int i = 0; i < propertyNames.length; i++) {
          props.put(propertyNames[i], event
              .getProperty(propertyNames[i]));
        }
        props.put(RemoteEventMessage.EVENT_SENDER_URI, networkChannel
            .getLocalAddress());
        msg.setProperties(props);
        send(msg);


        if (RemoteOSGiServiceImpl.MSG_DEBUG) {
          RemoteOSGiServiceImpl.log.log(LogService.LOG_DEBUG,
              "Forwarding Event " + event); //$NON-NLS-1$

Related Classes of ch.ethz.iks.r_osgi.messages.RemoteEventMessage

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.