Patched as per #476, no more errors at start up but cdr_billing fails after writing the following to the logs. Not sure if this should be its own thread…
May 3 09:21:28 y-mgmt0 YETI-cdr-billing[15645]: [09:21:28.862103 ] [ INFO]: [/home/yeti-web/pgq-processors/ext/pgq/lib/pgq/worker.rb: 50] {exit_code:1} Worker has been halted with ActiveRecord::StatementInvalid PG::RaiseException: ERROR: Not subscriber to queue: cdr_billing/cdr_billing#012CONTEXT: PL/pgSQL function pgq.next_batch_custom(text,text,interval,integer,interval) line 70 at RAISE#012SQL statement “select f.batch_id, f.cur_tick_id, f.prev_tick_id,#012 f.cur_tick_time, f.prev_tick_time,#012 f.cur_tick_event_seq, f.prev_tick_event_seq#012 from pgq.next_batch_custom(i_queue_name, i_consumer_name, NULL, NULL, NULL) f”#012PL/pgSQL function pgq.next_batch_info(text,text) line 33 at SQL statement#012SQL statement “select batch_id from pgq.next_batch_info(i_queue_name, i_consumer_name)”#012PL/pgSQL function pgq.next_batch(text,text) line 17 at SQL statement#012: SELECT pgq.next_batch(‘cdr_billing’, ‘cdr_billing’)
May 3 09:46:32 y-mgmt0 YETI-cdr-billing[16423]: [09:46:32.487649 ] [ INFO]: Worker for cdr_billing started
May 3 09:46:32 y-mgmt0 YETI-cdr-billing[16423]: [09:46:32.558663 ] [ERROR]: ActiveRecord::StatementInvalid PG::RaiseException: ERROR: Not subscriber to queue: cdr_billing/cdr_billing#012CONTEXT: PL/pgSQL function pgq.next_batch_custom(text,text,interval,integer,interval) line 70 at RAISE#012SQL statement “select f.batch_id, f.cur_tick_id, f.prev_tick_id,#012 f.cur_tick_time, f.prev_tick_time,#012 f.cur_tick_event_seq, f.prev_tick_event_seq#012 from pgq.next_batch_custom(i_queue_name, i_consumer_name, NULL, NULL, NULL) f”#012PL/pgSQL function pgq.next_batch_info(text,text) line 33 at SQL statement#012SQL statement “select batch_id from pgq.next_batch_info(i_queue_name, i_consumer_name)”#012PL/pgSQL function pgq.next_batch(text,text) line 17 at SQL statement#012: SELECT pgq.next_batch(‘cdr_billing’, ‘cdr_billing’)
May 3 09:46:33 y-mgmt0 YETI-cdr-billing[16423]: [09:46:33.329660 ] [ INFO]: [/home/yeti-web/pgq-processors/ext/pgq/lib/pgq/worker.rb: 50] {exit_code:1} Worker has been halted with ActiveRecord::StatementInvalid PG::RaiseException: ERROR: Not subscriber to queue: cdr_billing/cdr_billing#012CONTEXT: PL/pgSQL function pgq.next_batch_custom(text,text,interval,integer,interval) line 70 at RAISE#012SQL statement “select f.batch_id, f.cur_tick_id, f.prev_tick_id,#012 f.cur_tick_time, f.prev_tick_time,#012 f.cur_tick_event_seq, f.prev_tick_event_seq#012 from pgq.next_batch_custom(i_queue_name, i_consumer_name, NULL, NULL, NULL) f”#012PL/pgSQL function pgq.next_batch_info(text,text) line 33 at SQL statement#012SQL statement “select batch_id from pgq.next_batch_info(i_queue_name, i_consumer_name)”#012PL/pgSQL function pgq.next_batch(text,text) line 17 at SQL statement#012: SELECT pgq.next_batch(‘cdr_billing’, ‘cdr_billing’)
May 3 09:48:16 y-mgmt0 YETI-cdr-billing[16514]: [09:48:16.816477 ] [ INFO]: Worker for cdr_billing started
May 3 09:48:16 y-mgmt0 YETI-cdr-billing[16514]: [09:48:16.887129 ] [ERROR]: ActiveRecord::StatementInvalid PG::RaiseException: ERROR: Not subscriber to queue: cdr_billing/cdr_billing#012CONTEXT: PL/pgSQL function pgq.next_batch_custom(text,text,interval,integer,interval) line 70 at RAISE#012SQL statement "select f.batch_id, f.cur_tick_id, f.prev_tick_id,#012 f.cur_tick_time, f.prev_tick_time,#012 f.cur_tick_event_seq, f.prev_tick_event_se