Newer Version Available
Example: Subscribe to and Replay Events Using a Java Client
This code example implements Streaming API from a Java client using a library called Enterprise Messaging Platform (EMP) Connector. EMP connector is a thin wrapper around the CometD library. It hides the complexity of creating a CometD client and subscribing to Streaming API in Java. The example subscribes to a channel, receives notifications, and supports replaying events with durable streaming.
EMP Connector is based on Java 8 and uses CometD version 3.1.0. The connector supports PushTopic and generic streaming. It also supports username and password authentication and OAuth bearer token authentication.