Method List
-
#ack Pgque::Client
-
#batch_id Pgque::Message
-
#close Pgque::Client
-
#conn Pgque::Client
-
connect Pgque
-
connect Pgque::Client
-
#created_at Pgque::Message
-
#dead_interval Pgque::Consumer
-
#dsn Pgque::Consumer
-
#extra Pgque::Event
-
#extra1 Pgque::Message
-
#extra2 Pgque::Message
-
#extra3 Pgque::Message
-
#extra4 Pgque::Message
-
#force_next_tick Pgque::Client
-
#initialize Pgque::Event
-
#initialize Pgque::Client
-
#initialize Pgque::Message
-
#initialize Pgque::Consumer
-
#logger Pgque::Consumer
-
#max_messages Pgque::Consumer
-
#msg_id Pgque::Message
-
#nack Pgque::Client
-
#name Pgque::Consumer
-
#on Pgque::Consumer
-
#payload Pgque::Event
-
#payload Pgque::Message
-
#poll_interval Pgque::Consumer
-
#poll_once Pgque::Consumer
-
#queue Pgque::Consumer
-
#receive Pgque::Client
-
#receive_coop Pgque::Client
-
#retry_after Pgque::Consumer
-
#retry_count Pgque::Message
-
#running? Pgque::Consumer
-
#send Pgque::Client
-
#send_batch Pgque::Client
-
#start Pgque::Consumer
-
#stop Pgque::Consumer
-
#subconsumer Pgque::Consumer
-
#subscribe Pgque::Client
-
#subscribe_subconsumer Pgque::Client
-
#ticker Pgque::Client
-
#ticker_all Pgque::Client
-
#touch_subconsumer Pgque::Client
-
#type Pgque::Event
-
#type Pgque::Message
-
#unsubscribe Pgque::Client
-
#unsubscribe_subconsumer Pgque::Client