Add ErrorOnWriteListener property to ConnectionFactory

This way connection recovery triggering on write can be
disabled or customised.

[#154263515]

References #341

Author: acogoluegnes

src/main/java/com/rabbitmq/client/ConnectionFactory.java

@@ -141,6 +141,14 @@ public class ConnectionFactory implements Cloneable {
      */
     private boolean channelShouldCheckRpcResponseType = false;
 
+    /**
+     * Listener called when a connection gets an IO error trying to write on the socket.
+     * Default listener triggers connection recovery asynchronously and propagates
+     * the exception.
+     * @since 4.5.0
+     */
+    private ErrorOnWriteListener errorOnWriteListener;
+
     /**
      * Timeout in ms for work pool enqueuing.
      * @since 4.5.0
@@ -984,6 +992,7 @@ public ConnectionParams params(ExecutorService consumerWorkServiceExecutor) {
         result.setChannelRpcTimeout(channelRpcTimeout);
         result.setChannelShouldCheckRpcResponseType(channelShouldCheckRpcResponseType);
         result.setWorkPoolTimeout(workPoolTimeout);
+        result.setErrorOnWriteListener(errorOnWriteListener);
         return result;
     }
 
@@ -1292,7 +1301,9 @@ public boolean isChannelShouldCheckRpcResponseType() {
      * TCP connection failure. Note this shouldn't happen
      * with clients that set appropriate QoS values.
      * Default is no timeout.
+     *
      * @param workPoolTimeout timeout in ms
+     * @since 4.5.0
      */
     public void setWorkPoolTimeout(int workPoolTimeout) {
         this.workPoolTimeout = workPoolTimeout;
@@ -1301,4 +1312,17 @@ public void setWorkPoolTimeout(int workPoolTimeout) {
     public int getWorkPoolTimeout() {
         return workPoolTimeout;
     }
+
+    /**
+     * Set a listener to be called when connection gets an IO error trying to write on the socket.
+     * Default listener triggers connection recovery asynchronously and propagates
+     * the exception. Override the default listener to disable or
+     * customise automatic connection triggering on write operations.
+     *
+     * @param errorOnWriteListener the listener
+     * @since 4.5.0
+     */
+    public void setErrorOnWriteListener(ErrorOnWriteListener errorOnWriteListener) {
+        this.errorOnWriteListener = errorOnWriteListener;
+    }
 }

src/main/java/com/rabbitmq/client/impl/ErrorOnWriteListener.java

@@ -20,8 +20,10 @@
 import java.io.IOException;
 
 /**
- * Listener called when a connection gets an error trying to write on the socket.
+ * Listener called when a connection gets an IO error trying to write on the socket.
  * This can be used to trigger connection recovery.
+ *
+ * @since 4.5.0
  */
 public interface ErrorOnWriteListener {