Roger.ApplySystem (roger v4.0.0)

Copy Markdown View Source

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.

This is the apply part of system mostly just to handle NodeInfo requests. Split is done to reduce load of genserver.

Summary

Functions

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.

Functions

call(command, args \\ nil)

Execute a given command on all nodes, and wait for all nodes to return their values

cast(command, args \\ nil)

Execute a given command on all nodes, does not wait for their completion.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

connected?()

Return whether the node is connected to the AMQP broker

init(list)

Callback implementation for GenServer.init/1.