mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/DataStreamStoreNamespaceUtils.java
public static void disableArchiving(Socket socket, SharedMessages.UUID uuid, boolean errorExpected) 
            throws IOException
    {
        MessageListener listener = new MessageListener(socket);
        
        DisableArchivingRequestData request = DisableArchivingRequestData.newBuilder().
                setStreamProfileUuid(uuid).build();
        
        TerraHarvestMessage message = DataStreamStoreNamespaceUtils.createDataStreamStoreNamespaceMessage(
                DataStreamStoreMessageType.DisableArchivingRequest, request);
        message.writeDelimitedTo(socket.getOutputStream());

        if (errorExpected)
        {
            listener.waitForMessage(Namespace.Base, BaseMessageType.GenericErrorResponse, TIMEOUT);
        }
        else
        {
            listener.waitForMessage(Namespace.DataStreamStore, DataStreamStoreMessageType.DisableArchivingResponse, 
                    TIMEOUT);
        }
    }
/**
     * Disable archiving for a given stream profile instance.
     */
Disable archiving for a given stream profile instance.
Disable archiving for a given stream profile instance .
public static void disableArchiving(Socket socket, SharedMessages.UUID uuid, boolean errorExpected) 
            throws IOException
    {
        MessageListener listener = new MessageListener(socket);
        DisableArchivingRequestData request = DisableArchivingRequestData.newBuilder().
                setStreamProfileUuid(uuid).build();
        TerraHarvestMessage message = DataStreamStoreNamespaceUtils.createDataStreamStoreNamespaceMessage(
                DataStreamStoreMessageType.DisableArchivingRequest, request);
        message.writeDelimitedTo(socket.getOutputStream());
        if (errorExpected)
        {
            listener.waitForMessage(Namespace.Base, BaseMessageType.GenericErrorResponse, TIMEOUT);
        }
        else
        {
            listener.waitForMessage(Namespace.DataStreamStore, DataStreamStoreMessageType.DisableArchivingResponse, 
                    TIMEOUT);
        }
    }
public static void disableArchiving ( Socket socket , SharedMessages . UUID uuid , boolean errorExpected ) throws IOException { MessageListener listener = new MessageListener ( socket ) ; DisableArchivingRequestData request = DisableArchivingRequestData . newBuilder ( ) . setStreamProfileUuid ( uuid ) . build ( ) ; TerraHarvestMessage message = DataStreamStoreNamespaceUtils . createDataStreamStoreNamespaceMessage ( DataStreamStoreMessageType . DisableArchivingRequest , request ) ; message . writeDelimitedTo ( socket . getOutputStream ( ) ) ; if ( errorExpected ) { listener . waitForMessage ( Namespace . Base , BaseMessageType . GenericErrorResponse , TIMEOUT ) ; } else { listener . waitForMessage ( Namespace . DataStreamStore , DataStreamStoreMessageType . DisableArchivingResponse , TIMEOUT ) ; } }
Disable archiving for a given stream profile instance.
Disable archiving for a given stream profile instance .