diff --git a/command/agent/rpc.go b/command/agent/rpc.go index c4fe71f70..56d9bc7a3 100644 --- a/command/agent/rpc.go +++ b/command/agent/rpc.go @@ -304,11 +304,6 @@ func (i *AgentRPC) listen() { } client.dec = codec.NewDecoder(client.reader, msgpackHandle) client.enc = codec.NewEncoder(client.writer, msgpackHandle) - if err != nil { - i.logger.Printf("[ERR] agent.rpc: Failed to create decoder: %v", err) - conn.Close() - continue - } // Register the client i.Lock()