qbit
qbit copied to clipboard
enable same thread access checker for SendQueue processor
if (serviceThread.get() !=null && serviceThread.get() == Thread.currentThread()) {
mgmt.increment(name)
} else {
val thread = Thread.currentThread()
logger.info("Getting called from another thread {} not {}", thread.name, serviceThread.get()?.name ?: "not set")
}