com.pcbsys.nirvana.client.nQueueAsyncReader Class Reference

This Reader enables the client to receive all events asynchronous. More...

Inheritance diagram for com.pcbsys.nirvana.client.nQueueAsyncReader:
com.pcbsys.nirvana.client.nQueueReader com.pcbsys.nirvana.client.nQueueAsyncTransactionReader

Public Member Functions

String getReaderId () throws nSessionNotConnectedException
 Returns the server side unique id of the reader. More...
 
- Public Member Functions inherited from com.pcbsys.nirvana.client.nQueueReader
boolean hasConsumedEvents ()
 Method to see whether the reader has consumed any events. More...
 
boolean isClosed ()
 When a reader is closed, the physical subscription is closed at the server. More...
 
boolean isClosedLocally ()
 A reader can be closed, but the physical subscription queue is not closed at the server. More...
 
final nConsumeEvent[] peek (final nQueuePeekContext context) throws nSecurityException, nChannelNotFoundException, nSessionNotConnectedException, nRequestTimedOutException, nUnexpectedResponseException, nSessionPausedException, nIllegalArgumentException, nIllegalStateException
 Performs a non destructive read. More...
 

Additional Inherited Members

- Static Public Member Functions inherited from com.pcbsys.nirvana.client.nQueueReader
static nQueuePeekContext createContext ()
 Creates a Queue Peek Context, which is used to traverse the queue. More...
 
static nQueuePeekContext createContext (final int windowSize)
 Creates a Queue Peek Context, which is used to traverse the queue. More...
 
static nQueuePeekContext createContext (final int windowSize, final String selector)
 Creates a Queue Peek Context, which is used to traverse the queue. More...
 
- Protected Attributes inherited from com.pcbsys.nirvana.client.nQueueReader
final int myUniqueReaderId
 The unique id of this nQueueReader instance. More...
 

Detailed Description

This Reader enables the client to receive all events asynchronous.

The callback method was passed as part of the nQueueReaderContext. This class provides no pop methods, since it is all asynchronous delivery.

Member Function Documentation

String com.pcbsys.nirvana.client.nQueueAsyncReader.getReaderId ( ) throws nSessionNotConnectedException
virtual

Returns the server side unique id of the reader.

This ID can change after subscriber reconnect.

Returns
the unique reader id
Exceptions
nSessionNotConnectedException- if the session is not currently connected to the server.

Implements com.pcbsys.nirvana.client.nQueueReader.