- com
- pcbsys
- nirvana
- client
- nQueueSyncFragmentReader
This class provides the client with an synchronous interface into a Nirvana Queue. More...
Public Member Functions | |
| final nConsumeEvent | pop () throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
| This method places this client on the queue and will block until an event is placed onto the queue. More... | |
| final nConsumeEvent | pop (final long timeout) throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
| This method places this client on the queue and will block until an event is placed onto the queue or the specified timeout expires. More... | |
| final nConsumeEvent | pop (final long timeout, final String selector) throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
| This method places this client on the queue and will block until an event is placed onto the queue or the specified timeout expires. 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... | |
This class provides the client with an synchronous interface into a Nirvana Queue.
Events will only be delivered to this client when a call to pop is made and after all event fragments have been received.
| final nConsumeEvent com.pcbsys.nirvana.client.nQueueSyncFragmentReader.pop | ( | ) | throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
This method places this client on the queue and will block until an event is placed onto the queue.
This reader behaves exactly like the nQueueSyncReader with the exception that it understands fragmented events and will only return an event when all fragments are received.
| com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
| com.pcbsys.nirvana.client.nSecurityException | If your not authorized to perform the operation on the queue |
| com.pcbsys.nirvana.client.nSessionPausedException | The session is currently paused |
| com.pcbsys.nirvana.client.nIllegalStateException | This exception is raised if there is any issues with any of the arguments used by this method. One condition of this is if this object has been invalidated and no longer can be utilised, this can occur if a delete request has been issued to the connected server. |
| final nConsumeEvent com.pcbsys.nirvana.client.nQueueSyncFragmentReader.pop | ( | final long | timeout | ) | throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
This method places this client on the queue and will block until an event is placed onto the queue or the specified timeout expires.
This reader behaves exactly like the nQueueSyncReader with the exception that it understands fragmented events and will only return an event when all fragments are received. If the timeout expires it will return null
| timeout | Time to wait in milliseconds for an event |
| com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
| com.pcbsys.nirvana.client.nSecurityException | If your not authorized to perform the operation on the queue |
| com.pcbsys.nirvana.client.nSessionPausedException | The session is currently paused |
| com.pcbsys.nirvana.client.nIllegalStateException | This exception is raised if there is any issues with any of the arguments used by this method. One condition of this is if this object has been invalidated and no longer can be utilised, this can occur if a delete request has been issued to the connected server. |
| final nConsumeEvent com.pcbsys.nirvana.client.nQueueSyncFragmentReader.pop | ( | final long | timeout, |
| final String | selector | ||
| ) | throws nSessionNotConnectedException, nSessionPausedException, nSecurityException, nIllegalStateException |
This method places this client on the queue and will block until an event is placed onto the queue or the specified timeout expires.
This reader behaves exactly like the nQueueSyncReader with the exception that it understands fragmented events and will only return an event when all fragments are received. If the timeout expires it will return null
| timeout | Time to wait in milliseconds for an event |
| selector | the selection string used to filter events being popped |
| com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
| com.pcbsys.nirvana.client.nSecurityException | If your not authorized to perform the operation on the queue |
| com.pcbsys.nirvana.client.nSessionPausedException | The session is currently paused |
| com.pcbsys.nirvana.client.nIllegalStateException | This exception is raised if there is any issues with any of the arguments used by this method. One condition of this is if this object has been invalidated and no longer can be utilised, this can occur if a delete request has been issued to the connected server. |