Method: MessageBus::Backends::Postgres#global_unsubscribe

Defined in:
lib/message_bus/backends/postgres.rb

#global_unsubscribe ⇒ Object

Causes all subscribers to the bus to unsubscribe, and terminates the local connection. Typically used to reset tests.



337
338
339
340
 
# File 'lib/message_bus/backends/postgres.rb', line 337

def global_unsubscribe
  client.publish(postgresql_channel_name, UNSUB_MESSAGE)
  @subscribed = false
end