spark-streaming-message-listener