list.add(message);
}
// send events
System.out.println(" send " + list.size() + " " + _topic
+ " count events to " + producerId);
producer.send(_topic, new ByteBufferMessageSet(list));
// close all producers
for (SimpleProducer p : _producers) {
p.close();
}