Method read

java/tests/multirepo/MultiRepoWorker.java:119–161

()

    }

    public void read() {
        Subscriber subscriber =
            participant.create_subscriber(SUBSCRIBER_QOS_DEFAULT.get(), null, DEFAULT_STATUS_MASK.value);

        assert (subscriber != null);

        TheTransportRegistry.bind_config(transportConfig, subscriber);

        subscriber.create_datareader(topic, DATAREADER_QOS_DEFAULT.get(),
            new _DataReaderListenerLocalBase () {

                public void on_liveliness_changed(DataReader dr, LivelinessChangedStatus status) {}

                public void on_requested_deadline_missed(DataReader dr, RequestedDeadlineMissedStatus status) {}

                public void on_requested_incompatible_qos(DataReader dr, RequestedIncompatibleQosStatus status) {}

                public void on_sample_lost(DataReader reader, SampleLostStatus status) {}

                public void on_sample_rejected(DataReader dr, SampleRejectedStatus status) {}

                public void on_subscription_matched(DataReader dr, SubscriptionMatchedStatus status) {}

                public void on_data_available(DataReader dr) {
                    MessageDataReader reader = MessageDataReaderHelper.narrow(dr);

                    MessageHolder mh = new MessageHolder(new Message());

                    SampleInfo si = new SampleInfo();
                    si.source_timestamp = new DDS.Time_t();

                    SampleInfoHolder sih = new SampleInfoHolder(si);
                    reader.take_next_sample(mh, sih);

                    read = true;

                    if (si.valid_data) {
                        System.out.printf("[%s] read: \"%s\"\n", participant, mh.value.text);
                    }
                }
            }, DEFAULT_STATUS_MASK.value
        );
    }

    public boolean isRead() {
        return read;