leo_membership_mq_client

• Description
• Data Types
• Function Index
• Function Details

The membership operation’s messsage-queues client.

Behaviours: `leo_mq_behaviour <leo_mq_behaviour.html>`__.

References

• https://github.com/leo-project/leo_redundant_manager/blob/master/src/leo_membership_mq_client.erl

Description

The membership operation’s messsage-queues client

Data Types

type_of_server()

type_of_server() = manager | gateway | storage

Function Index

handle_call/1	Publish callback function.
handle_call/3
init/0	Initializer.
publish/3	Publish a message into the queue.
start/2	create queues and launch mq-servers.

Function Details

handle_call/1

handle_call(X1::{publish | consume, Id, Reply}) -> ok

• Id = any()
• Reply = any()

Publish callback function

handle_call/3

handle_call(X1, X2, X3) -> any()

init/0

init() -> ok

Initializer

publish/3

publish(ServerType, Node, Error) -> ok | {error, any()}

• ServerType = atom()
• Node = atom()
• Error = any()

Publish a message into the queue.

start/2

start(ServerType, RootPath) -> ok | {error, any()}

• ServerType = type_of_server()
• RootPath = string()

create queues and launch mq-servers.