diff --git a/zun/websocket/websocketproxy.py b/zun/websocket/websocketproxy.py index 3c95372d7..703f350fe 100644 --- a/zun/websocket/websocketproxy.py +++ b/zun/websocket/websocketproxy.py @@ -26,6 +26,7 @@ import time import docker from oslo_log import log as logging from oslo_utils import uuidutils +import six import six.moves.urllib.parse as urlparse import websockify @@ -120,6 +121,8 @@ class ZunProxyRequestHandlerBase(object): 'host': self.server.target_host, 'port': self.server.target_port}) raise self.CClose(1000, "Target closed") + if isinstance(buf, six.string_types): + buf = buf.encode() self.cqueue.append(buf) def do_websocket_proxy(self, target):