Method write

java/tests/multirepo/MultiRepoWorker.java:82–117

(final String text)

    }

    public void write(final String text) {
        Publisher publisher =
            participant.create_publisher(PUBLISHER_QOS_DEFAULT.get(), null, DEFAULT_STATUS_MASK.value);

        assert (publisher != null);

        TheTransportRegistry.bind_config(transportConfig, publisher);

        publisher.create_datawriter(topic, DATAWRITER_QOS_DEFAULT.get(),
            new _DataWriterListenerLocalBase() {
                public void on_liveliness_lost(DataWriter dw, LivelinessLostStatus status) {}

                public void on_offered_deadline_missed(DataWriter dw, OfferedDeadlineMissedStatus status) {}

                public void on_offered_incompatible_qos(DataWriter dw, OfferedIncompatibleQosStatus status) {}

                public void on_publication_matched(DataWriter dw, PublicationMatchedStatus status) {
                    if (status.total_count < 1) {
                        throw new IllegalArgumentException("Unable to match publication!");
                    }

                    MessageDataWriter writer = MessageDataWriterHelper.narrow(dw);

                    Message message = new Message();
                    message.text = text;

                    int handle = writer.register_instance(message);
                    if (writer.write(message, handle) != RETCODE_OK.value) {
                        throw new IllegalStateException("Unable to write message!");
                    }

                    System.out.printf("[%s] wrote %s\n", participant, message);
                }
            }, DEFAULT_STATUS_MASK.value
        );
    }

    public void read() {
        Subscriber subscriber =