Subscribe Using Direct Access Mode

Subscriber sub = p.createSubscriber(); sub.connect();
sub.subscribeStream(“stream1"); 
while (true) { 
	SubscriberEvent event = sub.getNextEvent(); 
	handleEvent(event); 
}