mil.dod.th.ose.remote/src/mil/dod/th/ose/remote/remoteconfiguration/RemoteChannelLookupMessageService.java
private Message syncTransportChannel(final TerraHarvestMessage message, 
            final RemoteChannelLookupNamespace namespaceMessage, final RemoteChannel channel) 
            throws InvalidProtocolBufferException
    {
        final SyncTransportChannelRequestData requestData = 
                SyncTransportChannelRequestData.parseFrom(namespaceMessage.getData());
        
        final TransportChannel newChannel = m_RemoteChannelLookup.syncTransportChannel(
                requestData.getTransportLayerName(), requestData.getDestSystemAddress(), 
                requestData.getRemoteSystemAddress(), requestData.getRemoteSystemId());
        
        final SyncTransportChannelResponseData responseData = SyncTransportChannelResponseData.newBuilder().
                setTransportLayerName(newChannel.getTransportLayerName()).
                setSourceSystemAddress(newChannel.getLocalMessageAddress()).// local address is source for response msg
                setRemoteSystemAddress(newChannel.getRemoteMessageAddress()).
                setRemoteSystemId(requestData.getRemoteSystemId()).
                build();
        
        m_MessageFactory.createRemoteChannelLookupResponseMessage(message,
                RemoteChannelLookupMessageType.SyncTransportChannelResponse, responseData).queue(channel);
        
        return requestData;
    }
/**
     * Handle syncing a transport channel.
     * @param message
     *     the message containing the information needed to process the request
     * @param namespaceMessage
     *     the namespace message that contains the actual request message data
     * @param channel
     *     the channel that the request come through
     * @return
     *     the request message
     * @throws InvalidProtocolBufferException
     *      if there is a failure while sending the response message
     *     Terra Harvest controller capabilities
     */
Handle syncing a transport channel.
Handle syncing a transport channel .
private Message syncTransportChannel(final TerraHarvestMessage message, 
            final RemoteChannelLookupNamespace namespaceMessage, final RemoteChannel channel) 
            throws InvalidProtocolBufferException
    {
        final SyncTransportChannelRequestData requestData = 
                SyncTransportChannelRequestData.parseFrom(namespaceMessage.getData());
        final TransportChannel newChannel = m_RemoteChannelLookup.syncTransportChannel(
                requestData.getTransportLayerName(), requestData.getDestSystemAddress(), 
                requestData.getRemoteSystemAddress(), requestData.getRemoteSystemId());
        final SyncTransportChannelResponseData responseData = SyncTransportChannelResponseData.newBuilder().
                setTransportLayerName(newChannel.getTransportLayerName()).
                setSourceSystemAddress(newChannel.getLocalMessageAddress()).
                setRemoteSystemAddress(newChannel.getRemoteMessageAddress()).
                setRemoteSystemId(requestData.getRemoteSystemId()).
                build();
        m_MessageFactory.createRemoteChannelLookupResponseMessage(message,
                RemoteChannelLookupMessageType.SyncTransportChannelResponse, responseData).queue(channel);
        return requestData;
    }
private Message syncTransportChannel ( final TerraHarvestMessage message , final RemoteChannelLookupNamespace namespaceMessage , final RemoteChannel channel ) throws InvalidProtocolBufferException { final SyncTransportChannelRequestData requestData = SyncTransportChannelRequestData . parseFrom ( namespaceMessage . getData ( ) ) ; final TransportChannel newChannel = m_RemoteChannelLookup . syncTransportChannel ( requestData . getTransportLayerName ( ) , requestData . getDestSystemAddress ( ) , requestData . getRemoteSystemAddress ( ) , requestData . getRemoteSystemId ( ) ) ; final SyncTransportChannelResponseData responseData = SyncTransportChannelResponseData . newBuilder ( ) . setTransportLayerName ( newChannel . getTransportLayerName ( ) ) . setSourceSystemAddress ( newChannel . getLocalMessageAddress ( ) ) . setRemoteSystemAddress ( newChannel . getRemoteMessageAddress ( ) ) . setRemoteSystemId ( requestData . getRemoteSystemId ( ) ) . build ( ) ; m_MessageFactory . createRemoteChannelLookupResponseMessage ( message , RemoteChannelLookupMessageType . SyncTransportChannelResponse , responseData ) . queue ( channel ) ; return requestData ; }
Handle syncing a transport channel.
Handle syncing a transport channel .
// local address is source for response msg