Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
This class has a grpc observer that queues recieved messages on a LinkedBlockingQueue and then has a separate thread pulling from the the queue to add to an executor.
Instead we could just add directly to the executor from the grpc stream, as the executor by default has an unbounded queue size (and there are comments indicating that a limited size executor can cause deadlocks otherwise)
Attachments
Issue Links
- links to