Listener for system-wide events.
On the AMQP side, the systemchannel declares a fanout exchange called 'system' and adds a private queue to it, which it consumes.
Summary
Functions
Return whether the node is active or shutting down
Execute a given command on all nodes, and wait for all nodes to return their values
Execute a given command on all nodes, does not wait for their completion.
Returns a specification to start this module under a supervisor.
Return whether the node is connected to the AMQP broker
Callback implementation for GenServer.init/1.
Set node to inactive so it can no longer start new partitions
Unsubscribe from all queues - ie. stop listening for jobs
Functions
Return whether the node is active or shutting down
Execute a given command on all nodes, and wait for all nodes to return their values
Execute a given command on all nodes, does not wait for their completion.
Returns a specification to start this module under a supervisor.
See Supervisor.
Return whether the node is connected to the AMQP broker
Callback implementation for GenServer.init/1.
Set node to inactive so it can no longer start new partitions
Unsubscribe from all queues - ie. stop listening for jobs