From 06e767e70ef53d683db1f8dd9cb5d2b15b95929f Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Mon, 28 Mar 2016 08:54:33 -0400
Subject: [PATCH] Fix handling of error messages in async

ConfluentNodeError branch of messages were not recognized.  Correct the oversight.
---
 confluent_server/confluent/messages.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/confluent_server/confluent/messages.py b/confluent_server/confluent/messages.py
index 573ce738..a4695804 100644
--- a/confluent_server/confluent/messages.py
+++ b/confluent_server/confluent/messages.py
@@ -853,7 +853,8 @@ class AsyncMessage(ConfluentMessage):
     def raw(self):
         rsp = self.msgpair[1]
         rspdict = None
-        if isinstance(rsp, ConfluentMessage):
+        if (isinstance(rsp, ConfluentMessage) or
+                isinstance(rsp, ConfluentNodeError)):
             rspdict = rsp.raw()
         elif isinstance(rsp, dict):  # console metadata
             rspdict = rsp