Method MultiRepoWorker

java/tests/multirepo/MultiRepoWorker.java:60–76

(DomainParticipant participant)

    private boolean read;

    public MultiRepoWorker(DomainParticipant participant) {
        assert (participant != null);

        this.participant = participant;

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

        topic = participant.create_topic("MultiRepo::Topic", typeSupport.get_type_name(),
                                         TOPIC_QOS_DEFAULT.get(), null, DEFAULT_STATUS_MASK.value);

        transportConfig = "" + ++transportId;

        assert (topic != null);
    }

    public DomainParticipant getParticipant() {
        return participant;