in lib/push_consumer.js [134:139]
subscribe(topic, expression) {
assert(this.status === START_STATUS.STOPPED);
assert(topic && typeof topic === "string");
assert(!expression || expression && typeof expression === "string");
return this.core.subscribe(topic, expression || "");
}