mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/observation/ObservationMessageService.java
private Message removeObservationByUUID(final TerraHarvestMessage message, 
        final ObservationStoreNamespace obsMessage, final RemoteChannel channel) throws InvalidProtocolBufferException 
    {
        //request to remove by UUID
        final RemoveObservationByUUIDRequestData request = RemoveObservationByUUIDRequestData.
            parseFrom(obsMessage.getData());

        //process request, by removing all requested observations
        for (UUID uuid : request.getUuidOfObservationList())
        {
            m_ObservationStore.remove(SharedMessageUtils.convertProtoUUIDtoUUID(uuid));
        }

        //send response
        m_MessageFactory.createObservationStoreResponseMessage(message, 
            ObservationStoreMessageType.RemoveObservationByUUIDResponse, null).queue(channel);

        //return request for the event
        return request;
    }
/**
     * Handle the request to delete an observation or observations by UUID. 
     * @param message
     *     message that contains the request parameters to use to query the observation store
     * @param obsMessage
     *     message containing the observation store namespace message
     * @param channel
     *     the channel from which the message originated from
     * @return
     *     the parsed data message
     * @throws InvalidProtocolBufferException 
     *     throw in the event that the namespace specific message could not be parsed
     */
Handle the request to delete an observation or observations by UUID.
Handle the request to delete an observation or observations by UUID .
private Message removeObservationByUUID(final TerraHarvestMessage message, 
        final ObservationStoreNamespace obsMessage, final RemoteChannel channel) throws InvalidProtocolBufferException 
    {
        final RemoveObservationByUUIDRequestData request = RemoveObservationByUUIDRequestData.
            parseFrom(obsMessage.getData());
        for (UUID uuid : request.getUuidOfObservationList())
        {
            m_ObservationStore.remove(SharedMessageUtils.convertProtoUUIDtoUUID(uuid));
        }
        m_MessageFactory.createObservationStoreResponseMessage(message, 
            ObservationStoreMessageType.RemoveObservationByUUIDResponse, null).queue(channel);
        return request;
    }
private Message removeObservationByUUID ( final TerraHarvestMessage message , final ObservationStoreNamespace obsMessage , final RemoteChannel channel ) throws InvalidProtocolBufferException { final RemoveObservationByUUIDRequestData request = RemoveObservationByUUIDRequestData . parseFrom ( obsMessage . getData ( ) ) ; for ( UUID uuid : request . getUuidOfObservationList ( ) ) { m_ObservationStore . remove ( SharedMessageUtils . convertProtoUUIDtoUUID ( uuid ) ) ; } m_MessageFactory . createObservationStoreResponseMessage ( message , ObservationStoreMessageType . RemoveObservationByUUIDResponse , null ) . queue ( channel ) ; return request ; }
Handle the request to delete an observation or observations by UUID.
Handle the request to delete an observation or observations by UUID .
//request to remove by UUID //process request, by removing all requested observations //send response //return request for the event