From 276b6d53e82ced03c88326692d73ffd3716dcf8e Mon Sep 17 00:00:00 2001
From: Ryland Degnan <ryland@netifi.io>
Date: Mon, 13 Nov 2017 16:54:49 -0800
Subject: [PATCH] Set refCnt back to 1 when recycling ByteBufPayload

---
 rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java b/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java
index a39214dfd..d20396852 100644
--- a/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java
+++ b/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java
@@ -159,6 +159,7 @@ public static Payload create(ByteBuf data) {
 
   public static Payload create(ByteBuf data, @Nullable ByteBuf metadata) {
     ByteBufPayload payload = RECYCLER.get();
+    payload.setRefCnt(1);
     payload.data = data;
     payload.metadata = metadata;
     return payload;