From f73281186ef2ededdc5164a04018ded95f408bdd Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Sun, 23 Sep 2018 11:46:07 -0700 Subject: [PATCH] fix #440 - rename reserved private key used by channel attributes cache --- src/main/java/reactor/netty/ReactorNetty.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/reactor/netty/ReactorNetty.java b/src/main/java/reactor/netty/ReactorNetty.java index 0c056474a6..ae31a35faa 100644 --- a/src/main/java/reactor/netty/ReactorNetty.java +++ b/src/main/java/reactor/netty/ReactorNetty.java @@ -611,9 +611,9 @@ public Mono then() { static final ConnectionObserver NOOP_LISTENER = (connection, newState) -> {}; static final Logger log = Loggers.getLogger(ReactorNetty.class); - static final AttributeKey PERSISTENT_CHANNEL = AttributeKey.newInstance("PERSISTENT_CHANNEL"); + static final AttributeKey PERSISTENT_CHANNEL = AttributeKey.newInstance("$PERSISTENT_CHANNEL"); - static final AttributeKey CONNECTION = AttributeKey.newInstance("CONNECTION"); + static final AttributeKey CONNECTION = AttributeKey.newInstance("$CONNECTION"); static final Consumer fileCloser = fc -> { try {