Mongo Change Stream Enhancer divides Change Stream events into partitions and enables you to handle them in separate Threads, increasing throughput. It achieves that by creating a Change Stream per each partition (number is configurable) and handling each Change Stream in a dedicated Thread.
Thread class is used internally by MongoChangeStreamWorker which is also Runnable.
This is not according to standards and probably should be corrected.
There are two possible solutions:
MongoChangeStreamWorker implements Runnable - recommended (without Thread inside, thread created in MongoCDCManager)
MongoChangeStreamWorker extends Thread - possible, but less preferable
MongoChangeStreamWorker can still refer to thread (if required at all) - via Thread.currentThread.
PiotrGravity
commented
9 months ago
Threadclass is used internally by MongoChangeStreamWorker which is also Runnable. This is not according to standards and probably should be corrected.There are two possible solutions:
MongoChangeStreamWorker can still refer to thread (if required at all) - via Thread.currentThread.