mil.dod.th.ose.core.integration/src/mil/dod/th/ose/core/integration/TestObservation.java
public void testObservationFilteringByAssetName() throws InterruptedException, 
        IllegalArgumentException, PersistenceFailedException, ValidationFailedException
    {
        EventHandlerSyncer syncer = new EventHandlerSyncer(m_Context, ObservationStore.TOPIC_OBSERVATION_PERSISTED, 
                String.format("(%s=%s)", FactoryDescriptor.EVENT_PROP_OBJ_NAME, "asset.name"));
        
        m_PersistedObservation = createTestObservation();
        m_ObservationStore.persist(m_PersistedObservation);
        
        syncer.waitForEvent(5);
    }
/**
     * Verify that event filter works when filtering by asset name.
     */
Verify that event filter works when filtering by asset name.
Verify that event filter works when filtering by asset name .
public void testObservationFilteringByAssetName() throws InterruptedException, 
        IllegalArgumentException, PersistenceFailedException, ValidationFailedException
    {
        EventHandlerSyncer syncer = new EventHandlerSyncer(m_Context, ObservationStore.TOPIC_OBSERVATION_PERSISTED, 
                String.format("(%s=%s)", FactoryDescriptor.EVENT_PROP_OBJ_NAME, "asset.name"));
        m_PersistedObservation = createTestObservation();
        m_ObservationStore.persist(m_PersistedObservation);
        syncer.waitForEvent(5);
    }
public void testObservationFilteringByAssetName ( ) throws InterruptedException , IllegalArgumentException , PersistenceFailedException , ValidationFailedException { EventHandlerSyncer syncer = new EventHandlerSyncer ( m_Context , ObservationStore . TOPIC_OBSERVATION_PERSISTED , String . format ( "(%s=%s)" , FactoryDescriptor . EVENT_PROP_OBJ_NAME , "asset.name" ) ) ; m_PersistedObservation = createTestObservation ( ) ; m_ObservationStore . persist ( m_PersistedObservation ) ; syncer . waitForEvent ( 5 ) ; }
Verify that event filter works when filtering by asset name.
Verify that event filter works when filtering by asset name .