Subscriber queue keeps growing in the server for a client that has become inactive. The queue processing thread in the server gets blocked in the socket during a write-operation, when the client stops reading data off the socket. However, keepAlives continue to be sent, thus keeping the connection active.