PitayaMQ

new WebSocketServer(\"producer\

writer

LocalConsumerTransferManager

PitayaProducer

ProducerWebSocketHandler

CassandraMetricService

ConsumerTransfer

transfer() {     notify(localQueue.pollAll())   }

MqConfig

new WebSocketServer(\"consumer\

LocalQueue localQueue 

LocalConsumerTransfer