Skip to content

Commit 8d426d8

Browse files
committed
Fixed #84
Missing OnPublishedWithSharedFilters in Hooks#HookBase.
1 parent ddf550a commit 8d426d8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

mqtt/hooks.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -923,8 +923,8 @@ func (h *HookBase) OnClientExpired(cl *Client) {}
923923
// OnRetainedExpired is called when a retained message for a topic has expired.
924924
func (h *HookBase) OnRetainedExpired(topic string) {}
925925

926-
// OnClusterPublish is called when a client has published a message to cluster.
927-
func (h *HookBase) OnClusterPublish(pk packets.Packet, sharedFilters map[string]bool) {}
926+
// OnPublishedWithSharedFilters is called when a client has published a message to cluster.
927+
func (h *HookBase) OnPublishedWithSharedFilters(pk packets.Packet, sharedFilters map[string]bool) {}
928928

929929
// StoredClients returns all clients from a store.
930930
func (h *HookBase) StoredClients() (v []storage.Client, err error) {

0 commit comments

Comments
 (0)