- com
- pcbsys
- nirvana
- base
- clientimpl
- multiconnection
- nSynchronousConsumerEventCallbackWrapper
This class serves as a wrapper for nPopQueue and nChannelIterate events. More...
Inherits nSynchronousCallbackWrapper.
Public Member Functions | |
| synchronized void | response (nEvent request, nEvent response) |
| Here we receive the response for the request by the reader thread We briefly check if this is a valid a response(i.e. More... | |
This class serves as a wrapper for nPopQueue and nChannelIterate events.
| synchronized void com.pcbsys.nirvana.base.clientimpl.multiconnection.nSynchronousConsumerEventCallbackWrapper.response | ( | nEvent | request, |
| nEvent | response | ||
| ) |
Here we receive the response for the request by the reader thread We briefly check if this is a valid a response(i.e.
has events), if it clear the countDownLatch If it's not (exception event or no events present) only decrement the countDownLatch. This way we ensure we do not wait more than needed on client side(the write thread)
| request | |
| response |