- com
- pcbsys
- nirvana
- client
- nQueueSyncTransactionFragmentReader
This reader provides a synchronous queue reader model. More...
Public Member Functions | |
final void | commit () throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Commits all received events so far. More... | |
final void | commit (final long eventId) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Committs all events up to the event id specified. More... | |
final void | commit (final long eventId, boolean ackPrevious) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Committs all events up to the event id specified. More... | |
final void | rollback () throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all received events that have not been committed or rollbacked previously. More... | |
final void | rollback (final long eventId) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all events up to the specified event id that have not been committed or rollbacked previously. More... | |
final void | rollback (final long eventId, boolean individualRollback) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all events up to the specified event id that have not been committed or rollbacked previously. More... | |
![]() | |
String | getReaderId () throws nSessionNotConnectedException |
Returns the server side unique id of the reader. More... | |
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... | |
![]() | |
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... | |
![]() | |
void | commit (long eventId) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Commits all events up to the event id specified. More... | |
void | commit (long eventId, boolean ackPrevious) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Commits all events up to the event id specified. More... | |
void | rollback (long eventId) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all events up to the specified event id that have not been committed or rollbacked previously. More... | |
void | rollback (long eventId, boolean isIndividual) throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
If isIndividual then this rolls back just the event with the specified event ID. More... | |
Additional Inherited Members | |
![]() | |
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... | |
![]() | |
final int | myUniqueReaderId |
The unique id of this nQueueReader instance. More... | |
This reader provides a synchronous queue reader model.
Where the client can pop()
events from the queue and then decide either to commit the event, ie. successfully processed it or to rollback, ie unable to process this event. This reader behaves exactly like the nQueueSyncTransactionReader with the exception that it understands fragmented events and will only return an event when all fragments are received. When the window size is reached and the client has yet to call commit or rollback the server will raise an exception on the pop()
command until the client has called either method.
final void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.commit | ( | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Commits all received events so far.
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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. |
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
final void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.commit | ( | final long | eventId | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Committs all events up to the event id specified.
This means you can partially commit received events.
eventId | Event ID to commit to, inclusive |
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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 void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.commit | ( | final long | eventId, |
boolean | ackPrevious | ||
) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Committs all events up to the event id specified.
This means you can partially commit received events.
eventId | Event ID to commit to, inclusive |
ackPrevious | if true then all events consumed prior to this eventId will also be committed (defaults to true) |
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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 void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.rollback | ( | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all received events that have not been committed or rollbacked previously.
These events are then pushed back onto the queue for redelivery.
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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. |
Implements com.pcbsys.nirvana.client.nQueueTransactionReader.
final void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.rollback | ( | final long | eventId | ) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all events up to the specified event id that have not been committed or rollbacked previously.
These events are then pushed back onto the queue for redelivery.
eventId | Event Id to rollback to, inclusive |
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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 void com.pcbsys.nirvana.client.nQueueSyncTransactionFragmentReader.rollback | ( | final long | eventId, |
boolean | individualRollback | ||
) | throws nSessionNotConnectedException, nSessionPausedException, nRequestTimedOutException, nIllegalStateException |
Rollbacks all events up to the specified event id that have not been committed or rollbacked previously.
These events are then pushed back onto the queue for redelivery.
eventId | Event Id to rollback to, inclusive |
individualRollback | if true, discard only this event and request redelivery. If false, keep this event but redeliver anything received after this event. |
com.pcbsys.nirvana.client.nSessionNotConnectedException | Client is not currently connected to the server |
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. |