mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/namespace/TestDataStreamStoreNamespace.java
@Test
    public final void testClientAck() throws IOException
    {
        Set<StreamProfile> profiles = DataStreamServiceNamespaceUtils.getStreamProfiles(socket);
        
        //Choose the first profile
        StreamProfile profile = (StreamProfile)profiles.toArray()[0];
        
        //Set archiving process to begin after 5 seconds if no client acknowledgment is received.
        DataStreamStoreNamespaceUtils.enableArchiving(socket, profile.getInfo().getUuid(), 5, false);

        //Send clientAck messages every second for 20 seconds to ensure that archiving process doesn't begin
        for (int i=0; i<20; i++)
        {
            try
            {
                DataStreamStoreNamespaceUtils.clientAck(socket, profile.getInfo().getUuid(), false);
                Thread.sleep(1000);
            }
            catch (InterruptedException e)
            {
                throw new IOException(e);
            }
        }
        
        //Disable process without any archiving having taken place.
        DataStreamStoreNamespaceUtils.disableArchiving(socket, profile.getInfo().getUuid(), false);       
    }
/**
     * Verify that a client acknowledgment can be sent for a stream profile to prevent an enabled archiving
     * process from entering archive mode.
     */
Verify that a client acknowledgment can be sent for a stream profile to prevent an enabled archiving
process from entering archive mode.
Verify that a client acknowledgment can be sent for a stream profile to prevent an enabled archiving process from entering archive mode .
@Test
    public final void testClientAck() throws IOException
    {
        Set<StreamProfile> profiles = DataStreamServiceNamespaceUtils.getStreamProfiles(socket);
        StreamProfile profile = (StreamProfile)profiles.toArray()[0];
        DataStreamStoreNamespaceUtils.enableArchiving(socket, profile.getInfo().getUuid(), 5, false);
        for (int i=0; i<20; i++)
        {
            try
            {
                DataStreamStoreNamespaceUtils.clientAck(socket, profile.getInfo().getUuid(), false);
                Thread.sleep(1000);
            }
            catch (InterruptedException e)
            {
                throw new IOException(e);
            }
        }
        DataStreamStoreNamespaceUtils.disableArchiving(socket, profile.getInfo().getUuid(), false);       
    }
@ Test public final void testClientAck ( ) throws IOException { Set < StreamProfile > profiles = DataStreamServiceNamespaceUtils . getStreamProfiles ( socket ) ; StreamProfile profile = ( StreamProfile ) profiles . toArray ( ) [ 0 ] ; DataStreamStoreNamespaceUtils . enableArchiving ( socket , profile . getInfo ( ) . getUuid ( ) , 5 , false ) ; for ( int i = 0 ; i < 20 ; i ++ ) { try { DataStreamStoreNamespaceUtils . clientAck ( socket , profile . getInfo ( ) . getUuid ( ) , false ) ; Thread . sleep ( 1000 ) ; } catch ( InterruptedException e ) { throw new IOException ( e ) ; } } DataStreamStoreNamespaceUtils . disableArchiving ( socket , profile . getInfo ( ) . getUuid ( ) , false ) ; }
Verify that a client acknowledgment can be sent for a stream profile to prevent an enabled archiving
 process from entering archive mode.
Verify that a client acknowledgment can be sent for a stream profile to prevent an enabled archiving process from entering archive mode .
//Choose the first profile //Set archiving process to begin after 5 seconds if no client acknowledgment is received. //Send clientAck messages every second for 20 seconds to ensure that archiving process doesn't begin //Disable process without any archiving having taken place.