mil.dod.th.ose.remote.integration/src/mil/dod/th/ose/remote/integration/base/TestRemoteObservationListener.java
public static void enableRemoteObservationStore(final boolean enabled) throws IOException, InterruptedException
    {
        Multitype value = Multitype.newBuilder().setBoolValue(enabled).setType(Type.BOOL).build();
        SimpleTypesMapEntry prop = SimpleTypesMapEntry.newBuilder().setKey("enabled").setValue(value).build();
        SetPropertyRequestData request = SetPropertyRequestData.newBuilder().
            setPid("mil.dod.th.ose.remote.observation.RemoteObservationListener").addProperties(prop).build();
        TerraHarvestMessage message = TestConfigAdminNamespace.createConfigAdminMessage(
            ConfigAdminMessageType.SetPropertyRequest, request);

        message.writeDelimitedTo(socket.getOutputStream());
        
        MessageListener listener = new MessageListener(socket);
        listener.waitForMessage(Namespace.ConfigAdmin, ConfigAdminMessageType.SetPropertyResponse, 1000);
    }
/**
     * Enable remote observation store listener.
     */
Enable remote observation store listener.
Enable remote observation store listener .
public static void enableRemoteObservationStore(final boolean enabled) throws IOException, InterruptedException
    {
        Multitype value = Multitype.newBuilder().setBoolValue(enabled).setType(Type.BOOL).build();
        SimpleTypesMapEntry prop = SimpleTypesMapEntry.newBuilder().setKey("enabled").setValue(value).build();
        SetPropertyRequestData request = SetPropertyRequestData.newBuilder().
            setPid("mil.dod.th.ose.remote.observation.RemoteObservationListener").addProperties(prop).build();
        TerraHarvestMessage message = TestConfigAdminNamespace.createConfigAdminMessage(
            ConfigAdminMessageType.SetPropertyRequest, request);
        message.writeDelimitedTo(socket.getOutputStream());
        MessageListener listener = new MessageListener(socket);
        listener.waitForMessage(Namespace.ConfigAdmin, ConfigAdminMessageType.SetPropertyResponse, 1000);
    }
public static void enableRemoteObservationStore ( final boolean enabled ) throws IOException , InterruptedException { Multitype value = Multitype . newBuilder ( ) . setBoolValue ( enabled ) . setType ( Type . BOOL ) . build ( ) ; SimpleTypesMapEntry prop = SimpleTypesMapEntry . newBuilder ( ) . setKey ( "enabled" ) . setValue ( value ) . build ( ) ; SetPropertyRequestData request = SetPropertyRequestData . newBuilder ( ) . setPid ( "mil.dod.th.ose.remote.observation.RemoteObservationListener" ) . addProperties ( prop ) . build ( ) ; TerraHarvestMessage message = TestConfigAdminNamespace . createConfigAdminMessage ( ConfigAdminMessageType . SetPropertyRequest , request ) ; message . writeDelimitedTo ( socket . getOutputStream ( ) ) ; MessageListener listener = new MessageListener ( socket ) ; listener . waitForMessage ( Namespace . ConfigAdmin , ConfigAdminMessageType . SetPropertyResponse , 1000 ) ; }
Enable remote observation store listener.
Enable remote observation store listener .