Method testElectionNews

java/tests/complex_idl/ComplexIDLTest.java:226–324

()

    }

    protected static void testElectionNews() throws Exception {
        final AtomicInteger count = new AtomicInteger();

        final Lock lock = new ReentrantLock();
        final Condition finished = lock.newCondition();

        publisher.create_datawriter(union_topic, DATAWRITER_QOS_DEFAULT.get(),
            new DDS._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) {
                    try {
                        if (status.current_count == 0) return;
                        // Don't run the rest of this method if the callback is
                        // due to the datareader going away.

                        ElectionNews_tDataWriter writer = ElectionNews_tDataWriterHelper.narrow(dw);

                        count.set(1);

                        ElectionNews_t data = new ElectionNews_t();
                        data.status(ElectionNewsType_t.ELECTION_STATUS, new Candidate_t("A Name", 10));

                        int result = writer.write(data, HANDLE_NIL.value);
                        assert (result != RETCODE_ERROR.value);

                    } catch (Throwable t) {
                        t.printStackTrace();
                    }
                };
            }, DEFAULT_STATUS_MASK.value
        );

        lock.lock();
        try {
            subscriber.create_datareader(union_topic, DATAREADER_QOS_DEFAULT.get(),
                new DDS._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 dr, 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) {
                        try {
                            ElectionNews_tDataReader reader = ElectionNews_tDataReaderHelper.narrow(dr);

                            ElectionNews_t en = new ElectionNews_t();