Method testQuotes

java/tests/complex_idl/ComplexIDLTest.java:91–224

()

    }

    protected static void testQuotes() throws Exception {
        System.out.println("And now for something completely different...");

        final AtomicInteger count = new AtomicInteger();

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

        publisher.create_datawriter(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.

                        DataDataWriter writer = DataDataWriterHelper.narrow(dw);

                        //NOTE: Since we are testing a complex type which contains a
                        //      union, both variants (DATA_IDL, DATA_STREAM) must be
                        //      tested on the same set of data:

                        List<Data> dataItems = new ArrayList<Data>();

                        for (Quote quote : quotes) {
                            // DATA_IDL
                            dataItems.add(createData(quote));

                            // DATA_STREAM
                            ByteArrayOutputStream out = new ByteArrayOutputStream();

                            ObjectOutputStream os = new ObjectOutputStream(out);
                            os.writeObject(quote.line); // Quote is not Serializable

                            dataItems.add(createData(out.toByteArray()));
                        }

                        count.set(dataItems.size());

                        for (Data data : dataItems) {
                            int result = writer.write(data, HANDLE_NIL.value);
                            assert (result != RETCODE_ERROR.value);
                        }

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

        lock.lock();