From 6b0e9046826c289c6a8696205f77e5ebad068d94 Mon Sep 17 00:00:00 2001 From: Ilko Date: Mon, 22 Jun 2015 14:59:34 +0300 Subject: [PATCH] Update PGQInteractiveConsumer.php --- PGQInteractiveConsumer.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/PGQInteractiveConsumer.php b/PGQInteractiveConsumer.php index 3fd7142..734575d 100644 --- a/PGQInteractiveConsumer.php +++ b/PGQInteractiveConsumer.php @@ -24,7 +24,7 @@ abstract class PGQInteractiveConsumer { public function __construct($qname, $cname, $src_constr, $loglevel, $logfile) { $this->qname = $qname; - $this->cname = $qname; + $this->cname = $cname; $this->src_constr = $src_constr; $this->pgcon = pg_connect($this->src_constr); @@ -158,7 +158,7 @@ protected function next_batch() { } protected function finish_batch($batch_id) { - return PGQ::next_batch($this->log, $this->pg_src_con, $batch_id); + return PGQ::finish_batch($this->log, $this->pg_src_con, $batch_id); } protected function get_batch_events($batch_id) { @@ -199,4 +199,4 @@ protected function failed_event_retry($event_id) { } } -?> \ No newline at end of file +?>