mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/AssetNamespaceUtils.java
public static SharedMessages.UUID requestDataCaptureReturnObsUuid(final Socket socket, 
            final SharedMessages.UUID uuid) throws IOException
    {
        MessageListener listener = new MessageListener(socket);

        //create request for the asset to capture
        CaptureDataRequestData captureData = CaptureDataRequestData.newBuilder()
            .setUuid(uuid)
            .setObservationFormat(RemoteTypesGen.LexiconFormat.Enum.UUID_ONLY).build();

        //terra harvest message to complete the request
        TerraHarvestMessage message = AssetNamespaceUtils.createAssetMessage(AssetMessageType.CaptureDataRequest, 
            captureData);

        //send request
        message.writeDelimitedTo(socket.getOutputStream());
        
        AssetNamespace response = (AssetNamespace)
                listener.waitForMessage(Namespace.Asset, AssetMessageType.CaptureDataResponse, 2000);
        
        return CaptureDataResponseData.parseFrom(response.getData()).getObservationUuid();
    }
/**
     * Request the specified asset to capture data. This is convenience method, which DOES wait for a response.
     * 
     * @param socket
     *     the socket connection to use
     * @param uuid
     *     the UUID protocol buffer message
     */
Request the specified asset to capture data. This is convenience method, which DOES wait for a response.

@param socket
the socket connection to use
@param uuid
the UUID protocol buffer message
Request the specified asset to capture data . This is convenience method which DOES wait for a response . @param socket the socket connection to use @param uuid the UUID protocol buffer message
public static SharedMessages.UUID requestDataCaptureReturnObsUuid(final Socket socket, 
            final SharedMessages.UUID uuid) throws IOException
    {
        MessageListener listener = new MessageListener(socket);
        CaptureDataRequestData captureData = CaptureDataRequestData.newBuilder()
            .setUuid(uuid)
            .setObservationFormat(RemoteTypesGen.LexiconFormat.Enum.UUID_ONLY).build();
        TerraHarvestMessage message = AssetNamespaceUtils.createAssetMessage(AssetMessageType.CaptureDataRequest, 
            captureData);
        message.writeDelimitedTo(socket.getOutputStream());
        AssetNamespace response = (AssetNamespace)
                listener.waitForMessage(Namespace.Asset, AssetMessageType.CaptureDataResponse, 2000);
        return CaptureDataResponseData.parseFrom(response.getData()).getObservationUuid();
    }
public static SharedMessages . UUID requestDataCaptureReturnObsUuid ( final Socket socket , final SharedMessages . UUID uuid ) throws IOException { MessageListener listener = new MessageListener ( socket ) ; CaptureDataRequestData captureData = CaptureDataRequestData . newBuilder ( ) . setUuid ( uuid ) . setObservationFormat ( RemoteTypesGen . LexiconFormat . Enum . UUID_ONLY ) . build ( ) ; TerraHarvestMessage message = AssetNamespaceUtils . createAssetMessage ( AssetMessageType . CaptureDataRequest , captureData ) ; message . writeDelimitedTo ( socket . getOutputStream ( ) ) ; AssetNamespace response = ( AssetNamespace ) listener . waitForMessage ( Namespace . Asset , AssetMessageType . CaptureDataResponse , 2000 ) ; return CaptureDataResponseData . parseFrom ( response . getData ( ) ) . getObservationUuid ( ) ; }
Request the specified asset to capture data.
Request the specified asset to capture data .
//create request for the asset to capture //terra harvest message to complete the request //send request