drop function search_observer__dequeue(integer,timestamptz,varchar);
drop function search_observer__enqueue(integer,varchar);