in src/main/java/com/aliyun/openservices/aliyun/log/producer/LogProducer.java [300:313]
public ListenableFuture<Result> send(
String project,
String logStore,
String topic,
String source,
String shardHash,
LogItem logItem,
Callback callback)
throws InterruptedException, ProducerException {
Utils.assertArgumentNotNull(logItem, "logItem");
List<LogItem> logItems = new ArrayList<LogItem>();
logItems.add(logItem);
return send(project, logStore, topic, source, shardHash, logItems, callback);
}