Added capping of buffer size, and switched to PUB-SUB scheme instead of PUSH-PULL since PUSH sockets block when the buffer is full
Added capping of buffer size, and switched to PUB-SUB scheme instead of PUSH-PULL since PUSH sockets block when the buffer is full

stopmachine/python-logstash