mil.dod.th.ose.datastream.store/src/mil/dod/th/ose/datastream/store/DataStreamStoreImpl.java
@Deactivate
    public void deactivate()
    {
        for (Entry<StreamProfile, ClientResponseThread> item : m_ClientResponseThreads.entrySet())
        {
            item.getValue().interrupt();
            try
            {
                item.getValue().join(THREAD_JOIN_TIME);
            }
            catch (final InterruptedException e)
            {
                m_LoggingService.error("Error joining client response thread");
            }
            
            try
            {
                m_ArchiverService.stop(item.getKey().getUuid().toString());
            }
            catch (final IllegalArgumentException e)
            {
                m_LoggingService.error("Error stopping archiver for id %s", item.getKey().getUuid().toString());
            }
           
        }
        
        m_ClientResponseThreads.clear();
        
    }
/**
     * Deactivate this service and halt any current archiving processes.
     */
Deactivate this service and halt any current archiving processes.
Deactivate this service and halt any current archiving processes .
@Deactivate
    public void deactivate()
    {
        for (Entry<StreamProfile, ClientResponseThread> item : m_ClientResponseThreads.entrySet())
        {
            item.getValue().interrupt();
            try
            {
                item.getValue().join(THREAD_JOIN_TIME);
            }
            catch (final InterruptedException e)
            {
                m_LoggingService.error("Error joining client response thread");
            }
            try
            {
                m_ArchiverService.stop(item.getKey().getUuid().toString());
            }
            catch (final IllegalArgumentException e)
            {
                m_LoggingService.error("Error stopping archiver for id %s", item.getKey().getUuid().toString());
            }
        }
        m_ClientResponseThreads.clear();
    }
@ Deactivate public void deactivate ( ) { for ( Entry < StreamProfile , ClientResponseThread > item : m_ClientResponseThreads . entrySet ( ) ) { item . getValue ( ) . interrupt ( ) ; try { item . getValue ( ) . join ( THREAD_JOIN_TIME ) ; } catch ( final InterruptedException e ) { m_LoggingService . error ( "Error joining client response thread" ) ; } try { m_ArchiverService . stop ( item . getKey ( ) . getUuid ( ) . toString ( ) ) ; } catch ( final IllegalArgumentException e ) { m_LoggingService . error ( "Error stopping archiver for id %s" , item . getKey ( ) . getUuid ( ) . toString ( ) ) ; } } m_ClientResponseThreads . clear ( ) ; }
Deactivate this service and halt any current archiving processes.
Deactivate this service and halt any current archiving processes .