bus

Documentation

Index

• func CommandsReqBus(router *message.Router, pub message.Publisher, sub message.Subscriber, ...) *message.Handler
• func MessageBus(router *message.Router, pub message.Publisher, sub message.Subscriber, ...)

Functions

func CommandsReqBus

func CommandsReqBus(router *message.Router,
	pub message.Publisher,
	sub message.Subscriber,
	reqCache *cache.Cache,
	deviceID string,
) *message.Handler

CommandsReqBus creates the commands request bus.

func MessageBus

func MessageBus(router *message.Router,
	pub message.Publisher,
	sub message.Subscriber,
	settings *config.CloudSettings,
	handlers []handlers.MessageHandler,
)

MessageBus creates the message bus for processing & forwarding the messages from the Subscriber to the Publisher.