 SECURITY DEFINER
 VOLATILE STRICT
 AS $BODY$
-/**
- * @author     Gavin M. Roy <gavinr@aweber.com>
- * @since      2015-12-23
- */
 BEGIN
   DELETE FROM mikkoo.audit WHERE message_id = in_message_id;
   RETURN FOUND;

Inserts an event into the specified pgq queue and a record into the audit table.
A message_id is automatically generated and set in the AMQP message properties.
The queue name is added to the AMQP headers message property under the key "pgq_queue"

INPUTS: queue - the queue the message was sent to
        exchange - the exchange the message should be published to

    headers TEXT;
    properties TEXT;
BEGIN
    SELECT uuid_generate_v4 INTO message_id FROM public.uuid_generate_v4();
    headers := '{"pgq_queue": "' || queue || '"}';
    properties := '{"message_id": "' || message_id || '"}';
