message_handler

Jun 4, 2023

Changes in this version

+ const KeyRedisOfflineMsgPrefix

+ var Enable = false

+ func AckOfflineMessage(id string)

+ func GetHandleFn() func(h *MessageHandler, ci *gate.Info, m *messages.GlideMessage)

+ func PushOfflineMessage(h *messaging.MessageInterfaceImpl, id string)

+ type InternalHandler struct

+ func (c *InternalHandler) Handle(h *messaging.MessageInterfaceImpl, cliInfo *gate.Info, ...) bool

type MessageHandler

+ func NewHandlerWithOptions(opts *Options) (*MessageHandler, error)

+ func (d *MessageHandler) AddHandler(i messaging.MessageHandler)

+ func (d *MessageHandler) InitDefaultHandler(...)

+ func (d *MessageHandler) SetOfflineMessageHandler(fn func(h *MessageHandler, ci *gate.Info, m *messages.GlideMessage))

+ func (d *MessageHandler) SetSubscription(s subscription.Interface)

+ type Options struct

+ Auth auth.Interface

+ DontInitDefaultHandler bool

+ MessageStore store.MessageStore

+ NotifyOnErr bool

+ OfflineHandleFn func(h *MessageHandler, ci *gate.Info, pushMessage *messages.GlideMessage)

May 27, 2022

Changes in this version

+ type AuthRequest struct

May 27, 2022

Changes in this version

+ type MessageHandler struct

+ func NewHandler(store store.MessageStore, auth auth.Interface) (*MessageHandler, error)

+ func (d *MessageHandler) Handle(cInfo *gate.Info, msg *messages.GlideMessage) error

+ func (d *MessageHandler) PutMessageHandler(action messages.Action, i messaging.HandlerFunc)

+ func (d *MessageHandler) SetAuthorize(a auth.Interface)

+ func (d *MessageHandler) SetGate(g gate.Gateway)