Konstantin Pavlov

Changed to default number of threads. You may extend 'createWorkerEventLoopGroup()' method in subclass. That's a quick fix, not necessary the best one.

See io.netty.channel.MultithreadEventLoopGroup#DEFAULT_EVENT_LOOP_THREADS ``` DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt( "io.netty.eventLoopThreads", NettyRuntime.availableProcessors() * 2)); ``` Maybe, you should tune boss EventLoopGroup ?com.github.kpavlov.jreactive8583.AbstractIso8583Connector#getBossEventLoopGroup

To limit the number of concurrent connections to your server - on a UNIX system - you can set the ulimit on file descriptors before running the application, and, once...

@mrtechit, Can you share your test please?

@mrtechit, I added [test ](https://github.com/kpavlov/jreactive-8583/blob/master/src/test/java/com/github/kpavlov/jreactive8583/example/LockDetectionIT.java) but can't reproduce it. Can you help me to reproduce?

If you do a blocking job - it deplets the thread pool and will eventually explode. Make sure the blocking job is executed on worker group event loop and increase...

Hi, I would suggest trying to test parsing guide against the j8583 library. My library does not deal with message parsing, it's responsibility of the MessageFactory

What are those messages? Echos?

Thanks. Am I right that providing I50Factory to the server or client does the job? ``` java I50Factory messageFactory = new I50Factory(SimpleTransformer.class); Iso8583Client client = new Iso8583Client(messageFactory); Iso8583Server server =...

Thank you, @Keyhan, send it please. BTW Channel.writeAndFlush is thread-safe so why should we synchronize externally?