Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.8.1
-
None
-
Windows 7
-
Unknown
Description
If user defined client pipeline factory is configured, Netty Producer shares the same instance of ClientPipelineFactory for all created connections. See code below:
configuration.getClientPipelineFactory().setProducer(this);
configuration.getClientPipelineFactory().setExchange(exchange);
configuration.getClientPipelineFactory().setCallback(callback);
clientPipeline = configuration.getClientPipelineFactory().getPipeline();
Which can cause an issue in multithreaded environment. Maybe it is better to create user defined client pipeline factory for each connection as it is done with DefaultClientPipelineFactory?