mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/namespace/TestObservationStoreMessageService.java
@Test
    public void testRemoveObservationUUID() throws IOException, InterruptedException
    {
        //message listener that will wait for responses
        MessageListener listener = new MessageListener(socket);

        //create observation
        SharedMessages.UUID observationUuid = AssetNamespaceUtils.requestDataCaptureReturnObsUuid(socket, assetUuid);

        //create remove request
        RemoveObservationByUUIDRequestData obsResquest = RemoveObservationByUUIDRequestData.newBuilder().
            addUuidOfObservation(observationUuid).build();

        //send request
        TerraHarvestMessage message = createObservationStoreMessage(
            ObservationStoreMessageType.RemoveObservationByUUIDRequest, obsResquest);

        //send request
        message.writeDelimitedTo(socket.getOutputStream());

        //wait for response
        listener.waitForMessage(Namespace.ObservationStore, 
            ObservationStoreMessageType.RemoveObservationByUUIDResponse, WAIT_TIME_MS);
    }
/**
     * Test removing observations from a remote system via UUID. 
     * 
     * Verify an observation UUID is returned.
     */
Test removing observations from a remote system via UUID.

Verify an observation UUID is returned.
Test removing observations from a remote system via UUID . Verify an observation UUID is returned .
@Test
    public void testRemoveObservationUUID() throws IOException, InterruptedException
    {
        MessageListener listener = new MessageListener(socket);
        SharedMessages.UUID observationUuid = AssetNamespaceUtils.requestDataCaptureReturnObsUuid(socket, assetUuid);
        RemoveObservationByUUIDRequestData obsResquest = RemoveObservationByUUIDRequestData.newBuilder().
            addUuidOfObservation(observationUuid).build();
        TerraHarvestMessage message = createObservationStoreMessage(
            ObservationStoreMessageType.RemoveObservationByUUIDRequest, obsResquest);
        message.writeDelimitedTo(socket.getOutputStream());
        listener.waitForMessage(Namespace.ObservationStore, 
            ObservationStoreMessageType.RemoveObservationByUUIDResponse, WAIT_TIME_MS);
    }
@ Test public void testRemoveObservationUUID ( ) throws IOException , InterruptedException { MessageListener listener = new MessageListener ( socket ) ; SharedMessages . UUID observationUuid = AssetNamespaceUtils . requestDataCaptureReturnObsUuid ( socket , assetUuid ) ; RemoveObservationByUUIDRequestData obsResquest = RemoveObservationByUUIDRequestData . newBuilder ( ) . addUuidOfObservation ( observationUuid ) . build ( ) ; TerraHarvestMessage message = createObservationStoreMessage ( ObservationStoreMessageType . RemoveObservationByUUIDRequest , obsResquest ) ; message . writeDelimitedTo ( socket . getOutputStream ( ) ) ; listener . waitForMessage ( Namespace . ObservationStore , ObservationStoreMessageType . RemoveObservationByUUIDResponse , WAIT_TIME_MS ) ; }
Test removing observations from a remote system via UUID.
Test removing observations from a remote system via UUID .
//message listener that will wait for responses //create observation //create remove request //send request //send request //wait for response