basic.QueueSinkUsage Class Reference

Push events into a QueueSink processor. More...

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Push events into a QueueSink processor.

Graphically, the queue sink is represented as follows:

Since it is a sink, it has no output stream.

The expected output of this program is:

Events in the sink: [foo, bar]
Events in the sink: [bar, baz]

Author

Sylvain Hallé Easy

Definition at line 41 of file QueueSinkUsage.java.

Member Function Documentation

main()

static void basic.QueueSinkUsage.main ( String []  args )

static

Create a sink

Definition at line 43 of file QueueSinkUsage.java.

    {
        /// Create a sink
        QueueSink sink = new QueueSink();
        // Get a reference to the sink's Pushable
        Pushable p = sink.getPushableInput();
        // Push a few events into the sink
        p.push("foo");
        p.push("bar");
        // Get a reference to the sink's queue, where events are stored
        Queue<Object> queue = sink.getQueue();
        System.out.println("Events in the sink: " + queue);
        // Events remain in the queue as long as you pop them out
        queue.remove(); // Removes the first event
        p.push("baz"); // Push another one
        System.out.println("Events in the sink: " + queue);
        ///
    }

---

The documentation for this class was generated from the following file:

• Source/src/basic/QueueSinkUsage.java