From bbe5e91ebce55083476924da89cb955a200be917 Mon Sep 17 00:00:00 2001
From: rstoyanchev <rstoyanchev@vmware.com>
Date: Mon, 12 Sep 2022 14:23:05 +0100
Subject: [PATCH] Minor change in ReactorNetty2TcpClient

A follow-up on recent addition of ReactorNetty2TcpClient and switch to
Netty 5 Buffer.
---
 .../messaging/tcp/reactor/ReactorNetty2TcpClient.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpClient.java b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpClient.java
index 70985b4d4b..e0192b68f7 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpClient.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpClient.java
@@ -340,7 +340,7 @@ public class ReactorNetty2TcpClient<P> implements TcpOperations<P> {
 		protected void decode(ChannelHandlerContext ctx, Buffer buffer) throws Exception {
 			ByteBuffer byteBuffer = ByteBuffer.allocate(buffer.readableBytes());
 			buffer.readBytes(byteBuffer);
-			byteBuffer.position(0);
+			byteBuffer.flip();
 			List<Message<P>> messages = this.codec.decode(byteBuffer);
 			for (Message<P> message : messages) {
 				ctx.fireChannelRead(message);