mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/observation/RemoteObservationListener.java
public void registerForObservationStore()
        {
            if (m_ServiceReg == null)
            {
                //dictionary of properties for the event handler for TOPIC_MESSAGE_RECEIVED events
                final Dictionary<String, Object> props = new Hashtable<String, Object>();
                final String[] topics = {
                    ObservationStore.TOPIC_OBSERVATION_MERGED_WITH_OBS + RemoteConstants.REMOTE_TOPIC_SUFFIX,
                    ObservationStore.TOPIC_OBSERVATION_PERSISTED_WITH_OBS + RemoteConstants.REMOTE_TOPIC_SUFFIX};
                props.put(EventConstants.EVENT_TOPIC, topics);

                //register the event handler
                m_ServiceReg = m_Context.registerService(EventHandler.class, this, props);
            }
        }
/**
         * Method to register this event handler for events with the {@link RemoteConstants#TOPIC_MESSAGE_RECEIVED}
         * topic from the ObservationStoreNamespace.
         */
Method to register this event handler for events with the  RemoteConstants#TOPIC_MESSAGE_RECEIVED
topic from the ObservationStoreNamespace.
Method to register this event handler for events with the RemoteConstants#TOPIC_MESSAGE_RECEIVED topic from the ObservationStoreNamespace .
public void registerForObservationStore()
        {
            if (m_ServiceReg == null)
            {
                final Dictionary<String, Object> props = new Hashtable<String, Object>();
                final String[] topics = {
                    ObservationStore.TOPIC_OBSERVATION_MERGED_WITH_OBS + RemoteConstants.REMOTE_TOPIC_SUFFIX,
                    ObservationStore.TOPIC_OBSERVATION_PERSISTED_WITH_OBS + RemoteConstants.REMOTE_TOPIC_SUFFIX};
                props.put(EventConstants.EVENT_TOPIC, topics);
                m_ServiceReg = m_Context.registerService(EventHandler.class, this, props);
            }
        }
public void registerForObservationStore ( ) { if ( m_ServiceReg == null ) { final Dictionary < String , Object > props = new Hashtable < String , Object > ( ) ; final String [ ] topics = { ObservationStore . TOPIC_OBSERVATION_MERGED_WITH_OBS + RemoteConstants . REMOTE_TOPIC_SUFFIX , ObservationStore . TOPIC_OBSERVATION_PERSISTED_WITH_OBS + RemoteConstants . REMOTE_TOPIC_SUFFIX } ; props . put ( EventConstants . EVENT_TOPIC , topics ) ; m_ServiceReg = m_Context . registerService ( EventHandler . class , this , props ) ; } }
Method to register this event handler for events with the {@link RemoteConstants#TOPIC_MESSAGE_RECEIVED}
 topic from the ObservationStoreNamespace.
Method to register this event handler for events with the { @link RemoteConstants#TOPIC_MESSAGE_RECEIVED } topic from the ObservationStoreNamespace .
//dictionary of properties for the event handler for TOPIC_MESSAGE_RECEIVED events //register the event handler