mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/DataStreamStoreNamespaceUtils.java
public static void enableArchiving(Socket socket, SharedMessages.UUID uuid, 
            long heartbeatPeriod, boolean errorExpected) throws IOException
    {
        MessageListener listener = new MessageListener(socket);
        
        EnableArchivingRequestData request = EnableArchivingRequestData.newBuilder().
                setStreamProfileUuid(uuid).
                setUseSourceBitrate(true).
                setHeartbeatPeriod(heartbeatPeriod).
                setDelay(0L).build();
        
        TerraHarvestMessage message = DataStreamStoreNamespaceUtils.createDataStreamStoreNamespaceMessage(
                DataStreamStoreMessageType.EnableArchivingRequest, request);
        message.writeDelimitedTo(socket.getOutputStream());

        if (errorExpected)
        {
            listener.waitForMessage(Namespace.Base, BaseMessageType.GenericErrorResponse, TIMEOUT);
        }
        else
        {
            listener.waitForMessage(Namespace.DataStreamStore, DataStreamStoreMessageType.EnableArchivingResponse, 
                    TIMEOUT);
        }
    }
/**
     * Enable archiving for a given stream profile instance.
     */
Enable archiving for a given stream profile instance.
Enable archiving for a given stream profile instance .
public static void enableArchiving(Socket socket, SharedMessages.UUID uuid, 
            long heartbeatPeriod, boolean errorExpected) throws IOException
    {
        MessageListener listener = new MessageListener(socket);
        EnableArchivingRequestData request = EnableArchivingRequestData.newBuilder().
                setStreamProfileUuid(uuid).
                setUseSourceBitrate(true).
                setHeartbeatPeriod(heartbeatPeriod).
                setDelay(0L).build();
        TerraHarvestMessage message = DataStreamStoreNamespaceUtils.createDataStreamStoreNamespaceMessage(
                DataStreamStoreMessageType.EnableArchivingRequest, request);
        message.writeDelimitedTo(socket.getOutputStream());
        if (errorExpected)
        {
            listener.waitForMessage(Namespace.Base, BaseMessageType.GenericErrorResponse, TIMEOUT);
        }
        else
        {
            listener.waitForMessage(Namespace.DataStreamStore, DataStreamStoreMessageType.EnableArchivingResponse, 
                    TIMEOUT);
        }
    }
public static void enableArchiving ( Socket socket , SharedMessages . UUID uuid , long heartbeatPeriod , boolean errorExpected ) throws IOException { MessageListener listener = new MessageListener ( socket ) ; EnableArchivingRequestData request = EnableArchivingRequestData . newBuilder ( ) . setStreamProfileUuid ( uuid ) . setUseSourceBitrate ( true ) . setHeartbeatPeriod ( heartbeatPeriod ) . setDelay ( 0L ) . build ( ) ; TerraHarvestMessage message = DataStreamStoreNamespaceUtils . createDataStreamStoreNamespaceMessage ( DataStreamStoreMessageType . EnableArchivingRequest , request ) ; message . writeDelimitedTo ( socket . getOutputStream ( ) ) ; if ( errorExpected ) { listener . waitForMessage ( Namespace . Base , BaseMessageType . GenericErrorResponse , TIMEOUT ) ; } else { listener . waitForMessage ( Namespace . DataStreamStore , DataStreamStoreMessageType . EnableArchivingResponse , TIMEOUT ) ; } }
Enable archiving for a given stream profile instance.
Enable archiving for a given stream profile instance .