in app/common/src/main/java/com/googlecodesamples/cloud/jss/common/service/BasePublisherService.java [38:42]
public BasePublisherService(Publisher publisher) {
this.totalMessage = new AtomicInteger(PubSubConst.INITIAL_TOTAL_MESSAGE);
this.publisher = publisher;
init();
}