Watchdog

com.github.badoualy.telegram.mtproto.MTProtoWatchdog

This class is a runnable that is using Java nio's Selector to listen for incoming messages on multiple connections in a single thread, then spawn a runnable in a CachedThreadPool to actually read the message and dispatch it to the connection's subscriber.

📘

Note

It's planned in the future to look for a library/implementation more stable and cleaner of this. This implementation works, but might not be optimal and contains unknown bugs.
I first tried to use netty, but it seems really complicate to implement, even to do basic stuff.


Did this page help you?