dispatcher

Documentation

Index

• func AddListenerToTopic(l *types.Listener)
• func DispatchMessage(m *types.Message)
• func GetAllListeners() []types.Listener
• func GetAllTopics() []string
• func GetDispatcher() *dispatcher
• func RemoveListener(l *types.Listener) error
• func StartDispatcher()

Functions

func AddListenerToTopic

func AddListenerToTopic(l *types.Listener)

AddListenerToTopic will add a listener to one of the topic's arrays so it can be notified since that moment of new messages

func DispatchMessage

func DispatchMessage(m *types.Message)

DispatchMessage takes a message and inserts it into the generic messages channel that will distribute it to the registered servers

func GetAllListeners

func GetAllListeners() []types.Listener

GetAllListeners will return an array with all listeners for each topic

func GetAllTopics

func GetAllTopics() []string

GetAllTopics will return an array of strings with the registered topic names

func GetDispatcher

func GetDispatcher() *dispatcher

func RemoveListener

func RemoveListener(l *types.Listener) error

RemoveListener takes a types.Listener and a topic and removes the listener from the the specified topic

func StartDispatcher

func StartDispatcher()