- com
- pcbsys
- nirvana
- base
- clientimpl
- multiconnection
- SynchronousEventConsumerManager
This class is responsible for processing of synchronous events (Readers and Iterators) in the HS layer. More...
Public Member Functions | |
| synchronized nEvent | getInboundEvent () |
| Iterates through the event callback wrappers and when it find a valid event allocates the event in the storeGroup which gives it a new ID and changes the current connection location Afterwards it gives the event to client. | |
| synchronized boolean | hasEventReady () |
| Checks if we have an event ready to be processed from event callback wrappers array if so get it and reset it's position so on a next call we will send a request. | |
| synchronized int | receiveCacheReturnOutstandingRequests (List< nPublished > listNPublished) |
| This method will return the number of synchronous poll requests that are awaiting reply from the server, while also extracting all of the cached events client-side. More... | |
| synchronized nSynchronousConsumerEventCallbackWrapper[] | requestIterateEvent (nChannelIterate channelIterate, boolean hasTimeout) |
| Iterates through the event callback wrappers and checks whether a new request with nChannelIterates for that connection should be send and and sets the CountDownLatch to appropriate value. More... | |
| synchronized nSynchronousConsumerEventCallbackWrapper[] | requestQueueEvents (nPopQueue popQueue, boolean hasTimeout) |
| Iterates through the event callback wrappers and checks whether a new request nPopQueues for that connection should be send and and sets the CountDownLatch to appropriate value. More... | |
| synchronized boolean | shouldAddIterator (int connectionIndex) |
| Check if we need to add an iterator on reconnect. | |
This class is responsible for processing of synchronous events (Readers and Iterators) in the HS layer.
| synchronized int com.pcbsys.nirvana.base.clientimpl.multiconnection.SynchronousEventConsumerManager.receiveCacheReturnOutstandingRequests | ( | List< nPublished > | listNPublished | ) |
This method will return the number of synchronous poll requests that are awaiting reply from the server, while also extracting all of the cached events client-side.
If the provided list is null, no cached events will be extracted.
| listNPublished | the list to be filled with the cached events |
| synchronized nSynchronousConsumerEventCallbackWrapper [] com.pcbsys.nirvana.base.clientimpl.multiconnection.SynchronousEventConsumerManager.requestIterateEvent | ( | nChannelIterate | channelIterate, |
| boolean | hasTimeout | ||
| ) |
Iterates through the event callback wrappers and checks whether a new request with nChannelIterates for that connection should be send and and sets the CountDownLatch to appropriate value.
| synchronized nSynchronousConsumerEventCallbackWrapper [] com.pcbsys.nirvana.base.clientimpl.multiconnection.SynchronousEventConsumerManager.requestQueueEvents | ( | nPopQueue | popQueue, |
| boolean | hasTimeout | ||
| ) |
Iterates through the event callback wrappers and checks whether a new request nPopQueues for that connection should be send and and sets the CountDownLatch to appropriate value.