From 5cc4080ccfbd7985075bf3645bddb2336c14fab4 Mon Sep 17 00:00:00 2001 From: Matt Jaffee Date: Fri, 14 Apr 2017 14:43:22 -0500 Subject: [PATCH] remove unused SetMessenger method --- gossip.go | 4 ---- messenger.go | 4 ---- 2 files changed, 8 deletions(-) diff --git a/gossip.go b/gossip.go index b25b634dd..9b18b45dd 100644 --- a/gossip.go +++ b/gossip.go @@ -138,10 +138,6 @@ func (g *GossipMessageBroker) Receive(pb proto.Message) error { return nil } -func (g *GossipMessageBroker) SetMessenger(m *Messenger) { - g.messenger = m -} - // implementation of the memberlist.Delegate interface func (g *GossipMessageBroker) NodeMeta(limit int) []byte { return []byte{} diff --git a/messenger.go b/messenger.go index 03e15ba0e..03579bee6 100644 --- a/messenger.go +++ b/messenger.go @@ -145,7 +145,6 @@ func (m *Messenger) mergeRemoteState(ns *internal.NodeState) error { type MessageBroker interface { Send(pb proto.Message, method string) error Receive(pb proto.Message) error - SetMessenger(m *Messenger) } ////////////////////////////////////////////////////////////////// @@ -167,7 +166,6 @@ func (c *nopMessageBroker) Receive(pb proto.Message) error { fmt.Println("NOPMessageBroker: Receive") return nil } -func (c *nopMessageBroker) SetMessenger(m *Messenger) {} ////////////////////////////////////////////////////////////////// @@ -217,8 +215,6 @@ func (h *HTTPMessageBroker) Receive(pb proto.Message) error { return nil } -func (h *HTTPMessageBroker) SetMessenger(m *Messenger) {} - func (h *HTTPMessageBroker) nodes() ([]*Node, error) { if h.messenger == nil { return nil, errors.New("HTTPMessageBroker has no reference to Messenger.")