diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/BinaryWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/BinaryWebSocketFrame.java index f4b4dc661e..450697b831 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/BinaryWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/BinaryWebSocketFrame.java @@ -58,4 +58,16 @@ public class BinaryWebSocketFrame extends WebSocketFrame { public BinaryWebSocketFrame copy() { return new BinaryWebSocketFrame(isFinalFragment(), rsv(), data().copy()); } + + @Override + public BinaryWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public BinaryWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/CloseWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/CloseWebSocketFrame.java index fa04a71085..3df1707d3b 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/CloseWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/CloseWebSocketFrame.java @@ -143,4 +143,16 @@ public class CloseWebSocketFrame extends WebSocketFrame { public CloseWebSocketFrame copy() { return new CloseWebSocketFrame(isFinalFragment(), rsv(), data().copy()); } + + @Override + public CloseWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public CloseWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/ContinuationWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/ContinuationWebSocketFrame.java index e5cd3b0ac0..08b45c8918 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/ContinuationWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/ContinuationWebSocketFrame.java @@ -124,4 +124,15 @@ public class ContinuationWebSocketFrame extends WebSocketFrame { return new ContinuationWebSocketFrame(isFinalFragment(), rsv(), data().copy(), aggregatedText()); } + @Override + public ContinuationWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public ContinuationWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PingWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PingWebSocketFrame.java index 9a96c620d8..63932a9320 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PingWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PingWebSocketFrame.java @@ -58,4 +58,16 @@ public class PingWebSocketFrame extends WebSocketFrame { public PingWebSocketFrame copy() { return new PingWebSocketFrame(isFinalFragment(), rsv(), data().copy()); } + + @Override + public PingWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public PingWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PongWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PongWebSocketFrame.java index fb97a70d81..c7af65e81b 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PongWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/PongWebSocketFrame.java @@ -59,4 +59,15 @@ public class PongWebSocketFrame extends WebSocketFrame { return new PongWebSocketFrame(isFinalFragment(), rsv(), data().copy()); } + @Override + public PongWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public PongWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/TextWebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/TextWebSocketFrame.java index 6a7ff3e6c2..99ad96732d 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/TextWebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/TextWebSocketFrame.java @@ -98,4 +98,16 @@ public class TextWebSocketFrame extends WebSocketFrame { public TextWebSocketFrame copy() { return new TextWebSocketFrame(isFinalFragment(), rsv(), data().copy()); } + + @Override + public TextWebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public TextWebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketFrame.java b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketFrame.java index 586f103336..e5bae05869 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketFrame.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketFrame.java @@ -67,4 +67,15 @@ public abstract class WebSocketFrame extends DefaultByteBufHolder { return getClass().getSimpleName() + "(data: " + data().toString() + ')'; } + @Override + public WebSocketFrame retain() { + super.retain(); + return this; + } + + @Override + public WebSocketFrame retain(int increment) { + super.retain(increment); + return this; + } }