mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/namespace/TestDataStreamStoreNamespace.java
@Test
    public final void testEnableAndDisableArchiving() throws IOException
    {
        Set<StreamProfile> profiles = DataStreamServiceNamespaceUtils.getStreamProfiles(socket);
        
        //Choose the first profile
        StreamProfile profile = (StreamProfile)profiles.toArray()[0];
        
        //Set archiving process to begin after 3 seconds if no client acknowledgment is received.
        DataStreamStoreNamespaceUtils.enableArchiving(socket, profile.getInfo().getUuid(), 3, false);
        
        //Wait for 10 seconds to ensure that archiving process begins
        try
        {
            Thread.sleep(10000);
        }
        catch (InterruptedException e)
        {
            throw new IOException(e);
        }
        
        //Disable currently running archive process
        DataStreamStoreNamespaceUtils.disableArchiving(socket, profile.getInfo().getUuid(), false);      
    }
/**
     * Verify that an archiving process can be enabled for a stream profile
     */
Verify that an archiving process can be enabled for a stream profile
Verify that an archiving process can be enabled for a stream profile
@Test
    public final void testEnableAndDisableArchiving() throws IOException
    {
        Set<StreamProfile> profiles = DataStreamServiceNamespaceUtils.getStreamProfiles(socket);
        StreamProfile profile = (StreamProfile)profiles.toArray()[0];
        DataStreamStoreNamespaceUtils.enableArchiving(socket, profile.getInfo().getUuid(), 3, false);
        try
        {
            Thread.sleep(10000);
        }
        catch (InterruptedException e)
        {
            throw new IOException(e);
        }
        DataStreamStoreNamespaceUtils.disableArchiving(socket, profile.getInfo().getUuid(), false);      
    }
@ Test public final void testEnableAndDisableArchiving ( ) throws IOException { Set < StreamProfile > profiles = DataStreamServiceNamespaceUtils . getStreamProfiles ( socket ) ; StreamProfile profile = ( StreamProfile ) profiles . toArray ( ) [ 0 ] ; DataStreamStoreNamespaceUtils . enableArchiving ( socket , profile . getInfo ( ) . getUuid ( ) , 3 , false ) ; try { Thread . sleep ( 10000 ) ; } catch ( InterruptedException e ) { throw new IOException ( e ) ; } DataStreamStoreNamespaceUtils . disableArchiving ( socket , profile . getInfo ( ) . getUuid ( ) , false ) ; }
Verify that an archiving process can be enabled for a stream profile
Verify that an archiving process can be enabled for a stream profile
//Choose the first profile //Set archiving process to begin after 3 seconds if no client acknowledgment is received. //Wait for 10 seconds to ensure that archiving process begins //Disable currently running archive process