fix #440 - rename reserved private key used by channel attributes cache

reactor · Sep 23, 2018 · f732811 · f732811
1 parent 4ce502f
commit f732811
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/reactor/netty/ReactorNetty.java b/src/main/java/reactor/netty/ReactorNetty.java
@@ -611,9 +611,9 @@ public Mono<Void> then() {
 	static final ConnectionObserver NOOP_LISTENER = (connection, newState) -> {};
 
 	static final Logger log                               = Loggers.getLogger(ReactorNetty.class);
-	static final AttributeKey<Boolean> PERSISTENT_CHANNEL = AttributeKey.newInstance("PERSISTENT_CHANNEL");
+	static final AttributeKey<Boolean> PERSISTENT_CHANNEL = AttributeKey.newInstance("$PERSISTENT_CHANNEL");
 
-	static final AttributeKey<Connection> CONNECTION = AttributeKey.newInstance("CONNECTION");
+	static final AttributeKey<Connection> CONNECTION = AttributeKey.newInstance("$CONNECTION");
 
 	static final Consumer<? super FileChannel> fileCloser = fc -> {
 		try {