mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/datastream/store/DataStreamStoreMessageService.java
private void clientAck(final DataStreamStoreNamespace message, final TerraHarvestMessage request,
            final RemoteChannel channel) throws IOException
    {
        final ClientAckData ack = ClientAckData.parseFrom(message.getData());

        try
        {

            final StreamProfile streamProfile = m_DataStreamService.getStreamProfile(
                    SharedMessageUtils.convertProtoUUIDtoUUID(ack.getStreamProfileUuid()));

            m_DataStreamStore.clientAck(streamProfile);

        }
        catch (final IllegalArgumentException e)
        {
            m_Logging.error(e, "Failed to perform acknowledgment for archiving process.");
            m_MessageFactory.createBaseErrorMessage(request, ErrorCode.ILLEGAL_STATE,
                    GENERIC_ERR_MSG + e.getMessage()).queue(channel);
        }

    }
/**
     * Method responsible for resetting the countdown timer for an archiving process.
     * 
     * @param message
     *      ClientAckData message containing a stream profile UUID
     * @param request
     *      entire remote message for the request
     * @param channel
     *      channel to use for sending a response
     * @throws IOException
     *      if message cannot be parsed
     */
Method responsible for resetting the countdown timer for an archiving process.

@param message
ClientAckData message containing a stream profile UUID
@param request
entire remote message for the request
@param channel
channel to use for sending a response
@throws IOException
if message cannot be parsed
Method responsible for resetting the countdown timer for an archiving process . @param message ClientAckData message containing a stream profile UUID @param request entire remote message for the request @param channel channel to use for sending a response @throws IOException if message cannot be parsed
private void clientAck(final DataStreamStoreNamespace message, final TerraHarvestMessage request,
            final RemoteChannel channel) throws IOException
    {
        final ClientAckData ack = ClientAckData.parseFrom(message.getData());
        try
        {
            final StreamProfile streamProfile = m_DataStreamService.getStreamProfile(
                    SharedMessageUtils.convertProtoUUIDtoUUID(ack.getStreamProfileUuid()));
            m_DataStreamStore.clientAck(streamProfile);
        }
        catch (final IllegalArgumentException e)
        {
            m_Logging.error(e, "Failed to perform acknowledgment for archiving process.");
            m_MessageFactory.createBaseErrorMessage(request, ErrorCode.ILLEGAL_STATE,
                    GENERIC_ERR_MSG + e.getMessage()).queue(channel);
        }
    }
private void clientAck ( final DataStreamStoreNamespace message , final TerraHarvestMessage request , final RemoteChannel channel ) throws IOException { final ClientAckData ack = ClientAckData . parseFrom ( message . getData ( ) ) ; try { final StreamProfile streamProfile = m_DataStreamService . getStreamProfile ( SharedMessageUtils . convertProtoUUIDtoUUID ( ack . getStreamProfileUuid ( ) ) ) ; m_DataStreamStore . clientAck ( streamProfile ) ; } catch ( final IllegalArgumentException e ) { m_Logging . error ( e , "Failed to perform acknowledgment for archiving process." ) ; m_MessageFactory . createBaseErrorMessage ( request , ErrorCode . ILLEGAL_STATE , GENERIC_ERR_MSG + e . getMessage ( ) ) . queue ( channel ) ; } }
Method responsible for resetting the countdown timer for an archiving process.
Method responsible for resetting the countdown timer for an archiving process .