@@ -1258,8 +1258,8 @@ socket is created separately and passed to the handler (as its 'queue')::
1258
1258
1259
1259
class ZeroMQSocketHandler(QueueHandler):
1260
1260
def enqueue(self, record):
1261
- data = json.dumps (record.__dict__)
1262
- self.queue.send(data)
1261
+ self.queue.send_json (record.__dict__)
1262
+
1263
1263
1264
1264
handler = ZeroMQSocketHandler(sock)
1265
1265
@@ -1272,11 +1272,10 @@ 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
- data = json.dumps(record.__dict__)
1279
- self.queue.send(data)
1278
+ self.queue.send_json(record.__dict__)
1280
1279
1281
1280
def close(self):
1282
1281
self.queue.close()
@@ -1292,12 +1291,13 @@ of queues, for example a ZeroMQ 'subscribe' socket. Here's an example::
1292
1291
def __init__(self, uri, *handlers, **kwargs):
1293
1292
self.ctx = kwargs.get('ctx') or zmq.Context()
1294
1293
socket = zmq.Socket(self.ctx, zmq.SUB)
1295
- socket.setsockopt (zmq.SUBSCRIBE, '') # subscribe to everything
1294
+ socket.setsockopt_string (zmq.SUBSCRIBE, '') # subscribe to everything
1296
1295
socket.connect(uri)
1296
+ super().__init__(socket, *handlers, **kwargs)
1297
1297
1298
1298
def dequeue(self):
1299
- msg = self.queue.recv ()
1300
- return logging.makeLogRecord(json.loads( msg) )
1299
+ msg = self.queue.recv_json ()
1300
+ return logging.makeLogRecord(msg)
1301
1301
1302
1302
1303
1303
.. seealso ::
0 commit comments