diff --git a/contrib/codecs/rdwr/codec.go b/contrib/codecs/rdwr/codec.go
index b50887c3d4be3df6f7b4efb4906ffc7e1d594eb9..0a6850a65f86164c3a428c3fd1f01f814716b5ae 100644
--- a/contrib/codecs/rdwr/codec.go
+++ b/contrib/codecs/rdwr/codec.go
@@ -21,7 +21,6 @@ type Codec struct {
 	wrLock sync.Mutex
 	wr     *bytes.Buffer
 	w      io.Writer
-	msgs   chan *serverutil.Bundle
 
 	dec     *json.Decoder
 	decBuf  json.RawMessage
@@ -32,13 +31,12 @@ func NewCodec(rd io.Reader, wr io.Writer) *Codec {
 	ctx, cn := context.WithCancel(context.TODO())
 	bufr := bufio.NewReader(rd)
 	c := &Codec{
-		ctx:  ctx,
-		cn:   cn,
-		rd:   bufr,
-		dec:  json.NewDecoder(rd),
-		wr:   new(bytes.Buffer),
-		w:    wr,
-		msgs: make(chan *serverutil.Bundle, 8),
+		ctx: ctx,
+		cn:  cn,
+		rd:  bufr,
+		dec: json.NewDecoder(rd),
+		wr:  new(bytes.Buffer),
+		w:   wr,
 	}
 	return c
 }