mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/datastream/store/DataStreamStoreMessageService.java
private Message disableArchiving(final DataStreamStoreNamespace message, final TerraHarvestMessage request,
            final RemoteChannel channel) throws IOException
    {
        final DisableArchivingRequestData disableRequest =
                DisableArchivingRequestData.parseFrom(message.getData());
        
        try
        {
            final StreamProfile streamProfile = m_DataStreamService.getStreamProfile(
                    SharedMessageUtils.convertProtoUUIDtoUUID(disableRequest.getStreamProfileUuid()));
            
            m_DataStreamStore.disableArchiving(streamProfile);
            
            m_MessageFactory.createDataStreamStoreResponseMessage(request, 
                    DataStreamStoreMessageType.DisableArchivingResponse, null).queue(channel); 
        }
        catch (final IllegalArgumentException e)
        {
            m_Logging.error(e, "Failed to disable archiving process.");
            m_MessageFactory.createBaseErrorMessage(request, ErrorCode.ILLEGAL_STATE,
                    GENERIC_ERR_MSG + e.getMessage()).queue(channel);
        }
        
        return disableRequest;

    }
/**
     * Method responsible for handling a remote request to disable an archiving process based on a
     * stream profile's UUID.
     * 
     * @param message
     *      DisableArchivingRequest message containing a stream profile UUID
     * @param request
     *      entire remote message for the request
     * @param channel
     *      channel to use for sending a response
     * @return
     *      the data message for this request
     * @throws IOException
     *      if message cannot be parsed
     */
Method responsible for handling a remote request to disable an archiving process based on a
stream profile's UUID.


Method responsible for handling a remote request to disable an archiving process based on a stream profile ' s UUID .
private Message disableArchiving(final DataStreamStoreNamespace message, final TerraHarvestMessage request,
            final RemoteChannel channel) throws IOException
    {
        final DisableArchivingRequestData disableRequest =
                DisableArchivingRequestData.parseFrom(message.getData());
        try
        {
            final StreamProfile streamProfile = m_DataStreamService.getStreamProfile(
                    SharedMessageUtils.convertProtoUUIDtoUUID(disableRequest.getStreamProfileUuid()));
            m_DataStreamStore.disableArchiving(streamProfile);
            m_MessageFactory.createDataStreamStoreResponseMessage(request, 
                    DataStreamStoreMessageType.DisableArchivingResponse, null).queue(channel); 
        }
        catch (final IllegalArgumentException e)
        {
            m_Logging.error(e, "Failed to disable archiving process.");
            m_MessageFactory.createBaseErrorMessage(request, ErrorCode.ILLEGAL_STATE,
                    GENERIC_ERR_MSG + e.getMessage()).queue(channel);
        }
        return disableRequest;
    }
private Message disableArchiving ( final DataStreamStoreNamespace message , final TerraHarvestMessage request , final RemoteChannel channel ) throws IOException { final DisableArchivingRequestData disableRequest = DisableArchivingRequestData . parseFrom ( message . getData ( ) ) ; try { final StreamProfile streamProfile = m_DataStreamService . getStreamProfile ( SharedMessageUtils . convertProtoUUIDtoUUID ( disableRequest . getStreamProfileUuid ( ) ) ) ; m_DataStreamStore . disableArchiving ( streamProfile ) ; m_MessageFactory . createDataStreamStoreResponseMessage ( request , DataStreamStoreMessageType . DisableArchivingResponse , null ) . queue ( channel ) ; } catch ( final IllegalArgumentException e ) { m_Logging . error ( e , "Failed to disable archiving process." ) ; m_MessageFactory . createBaseErrorMessage ( request , ErrorCode . ILLEGAL_STATE , GENERIC_ERR_MSG + e . getMessage ( ) ) . queue ( channel ) ; } return disableRequest ; }
Method responsible for handling a remote request to disable an archiving process based on a
 stream profile's UUID.
Method responsible for handling a remote request to disable an archiving process based on a stream profile ' s UUID .