@@ -1259,7 +1259,7 @@ socket is created separately and passed to the handler (as its 'queue')::
1259
1259
class ZeroMQSocketHandler(QueueHandler):
1260
1260
def enqueue(self, record):
1261
1261
data = json.dumps(record.__dict__)
1262
- self.queue.send (data)
1262
+ self.queue.send_string (data)
1263
1263
1264
1264
handler = ZeroMQSocketHandler(sock)
1265
1265
@@ -1272,11 +1272,11 @@ data needed by the handler to create the socket::
1272
1272
self.ctx = ctx or zmq.Context()
1273
1273
socket = zmq.Socket(self.ctx, socktype)
1274
1274
socket.bind(uri)
1275
- QueueHandler .__init__(self, socket)
1275
+ super() .__init__(socket)
1276
1276
1277
1277
def enqueue(self, record):
1278
1278
data = json.dumps(record.__dict__)
1279
- self.queue.send (data)
1279
+ self.queue.send_string (data)
1280
1280
1281
1281
def close(self):
1282
1282
self.queue.close()
@@ -1292,8 +1292,9 @@ of queues, for example a ZeroMQ 'subscribe' socket. Here's an example::
1292
1292
def __init__(self, uri, *handlers, **kwargs):
1293
1293
self.ctx = kwargs.get('ctx') or zmq.Context()
1294
1294
socket = zmq.Socket(self.ctx, zmq.SUB)
1295
- socket.setsockopt (zmq.SUBSCRIBE, '') # subscribe to everything
1295
+ socket.setsockopt_string (zmq.SUBSCRIBE, '') # subscribe to everything
1296
1296
socket.connect(uri)
1297
+ super().__init__(socket, *handlers, **kwargs)
1297
1298
1298
1299
def dequeue(self):
1299
1300
msg = self.queue.recv()
0 commit comments