-- ----------------------------------------------------------------------
-- Function: pgq.unregister_consumer(2)
--
--- Unsubscriber consumer from the queue. Also consumer's failed
--- and retry events are deleted.
+-- Unsubscriber consumer from the queue. Also consumer's
+-- retry events are deleted.
--
-- Parameters:
-- x_queue_name - Name of the queue
-- pgq.tick - Per-queue snapshots (ticks)
-- pgq.event_* - Data tables
-- pgq.retry_queue - Events to be retried later
--- pgq.failed_queue - Events whose processing failed
--
-- Its basically generalized and simplified Slony-I structure:
-- sl_node - pgq.consumer
-- ----------------------------------------------------------------------
create table pgq.consumer (
co_id serial,
- co_name text not null default 'fooz',
+ co_name text not null,
constraint consumer_pkey primary key (co_id),
constraint consumer_name_uq UNIQUE (co_name)