flume custom hazelcast queue source