mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/RemoteChannelLookupImpl.java
private void restoreChannels()
    {
        m_Restoring = true;
        
        // read data from persistent store for each system
        final Collection<PersistentData> systemChannelDataList = m_PersistentDataStore.query(getClass());
        for (PersistentData systemChannelData : systemChannelDataList)
        {
            final SystemChannels systemChannels;
            try
            {
                systemChannels = SystemChannels.parseFrom((byte[])systemChannelData.getEntity());
            }
            catch (final InvalidProtocolBufferException e)
            {
                m_Logging.error(e, "Unable to parse channel for system %s", systemChannelData.getDescription());
                return;
            }
            
            // restore all socket channels
            for (SocketChannelType socketChannel : systemChannels.getSocketChannelList())
            {
                syncClientSocketChannel(socketChannel.getHost(), socketChannel.getPort(), systemChannels.getSysId(),
                        true, socketChannel.getSslEnabled());
            }
            
            // restore all transport channels
            for (TransportChannelType transportChannel : systemChannels.getTransportChannelList())
            {
                syncTransportChannel(transportChannel.getTransportName(), transportChannel.getLocalAddress(), 
                        transportChannel.getRemoteAddress(), systemChannels.getSysId());
            }
        }
        
        m_Restoring = false;
    }
/**
     * Restore all previously saved channels.
     */
Restore all previously saved channels.
Restore all previously saved channels .
private void restoreChannels()
    {
        m_Restoring = true;
        final Collection<PersistentData> systemChannelDataList = m_PersistentDataStore.query(getClass());
        for (PersistentData systemChannelData : systemChannelDataList)
        {
            final SystemChannels systemChannels;
            try
            {
                systemChannels = SystemChannels.parseFrom((byte[])systemChannelData.getEntity());
            }
            catch (final InvalidProtocolBufferException e)
            {
                m_Logging.error(e, "Unable to parse channel for system %s", systemChannelData.getDescription());
                return;
            }
            for (SocketChannelType socketChannel : systemChannels.getSocketChannelList())
            {
                syncClientSocketChannel(socketChannel.getHost(), socketChannel.getPort(), systemChannels.getSysId(),
                        true, socketChannel.getSslEnabled());
            }
            for (TransportChannelType transportChannel : systemChannels.getTransportChannelList())
            {
                syncTransportChannel(transportChannel.getTransportName(), transportChannel.getLocalAddress(), 
                        transportChannel.getRemoteAddress(), systemChannels.getSysId());
            }
        }
        m_Restoring = false;
    }
private void restoreChannels ( ) { m_Restoring = true ; final Collection < PersistentData > systemChannelDataList = m_PersistentDataStore . query ( getClass ( ) ) ; for ( PersistentData systemChannelData : systemChannelDataList ) { final SystemChannels systemChannels ; try { systemChannels = SystemChannels . parseFrom ( ( byte [ ] ) systemChannelData . getEntity ( ) ) ; } catch ( final InvalidProtocolBufferException e ) { m_Logging . error ( e , "Unable to parse channel for system %s" , systemChannelData . getDescription ( ) ) ; return ; } for ( SocketChannelType socketChannel : systemChannels . getSocketChannelList ( ) ) { syncClientSocketChannel ( socketChannel . getHost ( ) , socketChannel . getPort ( ) , systemChannels . getSysId ( ) , true , socketChannel . getSslEnabled ( ) ) ; } for ( TransportChannelType transportChannel : systemChannels . getTransportChannelList ( ) ) { syncTransportChannel ( transportChannel . getTransportName ( ) , transportChannel . getLocalAddress ( ) , transportChannel . getRemoteAddress ( ) , systemChannels . getSysId ( ) ) ; } } m_Restoring = false ; }
Restore all previously saved channels.
Restore all previously saved channels .
// read data from persistent store for each system // restore all socket channels // restore all transport channels