Use HTTP headers for Websocket connection
This commit is contained in:
parent
2e2496cd4c
commit
c82a8301bb
1 changed files with 6 additions and 1 deletions
|
|
@ -121,8 +121,13 @@ class _WebsocketTransport(_AbstractTransport):
|
||||||
url = '%s://%s/websocket/%s' % (
|
url = '%s://%s/websocket/%s' % (
|
||||||
'wss' if is_secure else 'ws',
|
'wss' if is_secure else 'ws',
|
||||||
base_url, socketIO_session.id)
|
base_url, socketIO_session.id)
|
||||||
|
|
||||||
|
http_session = _prepare_http_session(kw)
|
||||||
|
req = http_session.prepare_request(requests.Request('GET', url))
|
||||||
|
headers = ['%s: %s' % item for item in req.headers.iteritems()]
|
||||||
|
|
||||||
try:
|
try:
|
||||||
self._connection = websocket.create_connection(url)
|
self._connection = websocket.create_connection(url, header=headers)
|
||||||
except socket.timeout as e:
|
except socket.timeout as e:
|
||||||
raise ConnectionError(e)
|
raise ConnectionError(e)
|
||||||
except socket.error as e:
|
except socket.error as e:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue