scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove unused SetMessenger method

Browse source
This commit is contained in:
Matt Jaffee 2017-04-14 14:43:22 -05:00 • committed by Travis
parent b0f1fc7523
commit 5cc4080ccf
2 changed files with 0 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
gossip.go
View file

@ -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{}

4
messenger.go
View file

@ -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.")