mirror of
https://github.com/corda/corda.git
synced 2025-03-16 00:55:24 +00:00
* ENT-2636: Introduce ModeSelectingChannel Next step: Add an integration test. * ENT-2636: Explicitly retain/release ByteBuf * ENT-2636: Use ByteBuf API and stop using `java.nio.ByteBuffer` * ENT-2636: Add new optional FirewallConfiguration parameter * ENT-2636: Simplify implementation of ModeSelectingChannel * ENT-2610: Create integration test to check response on TCP call and fixes to ModeSelectingChannel * ENT-2610: Extend integration test fixes to ModeSelectingChannel Doesn't currently work well for longer messages. * ENT-2610: Extend integration test fixes to ModeSelectingChannel Doesn't currently work well for longer messages. * ENT-2610: Fixes to ModeSelectingChannel so it works well for longer messages. * ENT-2610: Reflect `healthCheckPhrase` from `FirewallConfiguration` onto `AMQPConfiguration` * ENT-2610: Incorporate review comments by @mnesbit * ENT-2636: Extend the test to drip feed bytes one-by-one. Also remove TRACE level packet logging for speed and log space reduction. Logging-wise the following printed into the log every time TCP echo performed: ``` [INFO] 11:03:16,016 [nioEventLoopGroup-5-1] logging.LoggingHandler.info - [id: 0x202c2137, L:/0:0:0:0:0:0:0:0:10001] READ: [id: 0x073fda76, L:/10.18.1.203:10001 - R:/10.18.1.203:59274] [INFO] 11:03:16,016 [nioEventLoopGroup-5-1] logging.LoggingHandler.info - [id: 0x202c2137, L:/0:0:0:0:0:0:0:0:10001] READ COMPLETE [INFO] 11:03:16,018 [nioEventLoopGroup-6-4] netty.AMQPChannelHandler.invoke - New client connection 073fda76 from /10.18.1.203:59274 to /10.18.1.203:10001 {allowedRemoteLegalNames=null, localCert=null, remoteAddress=/10.18.1.203:59274, remoteCert=null, serverMode=true} ```