Method setUp

java/tests/builtintopics/BuiltinTopicsTest.java:64–79

(String[] args)

    private static Topic topic;

    protected static void setUp(String[] args) {
        dpf = TheParticipantFactory.WithArgs(new StringSeqHolder(args));

        participant =
            dpf.create_participant(DOMAIN_ID, PARTICIPANT_QOS_DEFAULT.get(), null, DEFAULT_STATUS_MASK.value);

        builtinSubscriber = participant.get_builtin_subscriber();

        MessageTypeSupport typeSupport = new MessageTypeSupportImpl();
        if (typeSupport.register_type(participant, "Messenger::Message") != RETCODE_OK.value) {
            throw new IllegalStateException("Unable to register type!");
        }

        topic = participant.create_topic("BuiltinTopics::Topic", typeSupport.get_type_name(),
                                         TOPIC_QOS_DEFAULT.get(), null, 0);
    }

    private static boolean waitForSample(DataReader dr) {
        DDS.ReadCondition dr_rc = dr.create_readcondition(ANY_SAMPLE_STATE.value, ANY_VIEW_STATE.value, ALIVE_INSTANCE_STATE.value);