Resolve consensus message sub error (#137)

[bytom/vapor.git] / netsync / consensusmgr / handle.go

diff --git a/netsync/consensusmgr/handle.go b/netsync/consensusmgr/handle.go
index 67fec0c..668a2f7 100644 (file)
--- a/netsync/consensusmgr/handle.go
+++ b/netsync/consensusmgr/handle.go
@@ -102,7 +102,7 @@ func (m *Manager) handleBlockSignatureMsg(peerID string, msg *BlockSignatureMsg)
 }
 
 func (m *Manager) blockProposeMsgBroadcastLoop() {
-       blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewBlockProposeEvent{})
+       blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewProposedBlockEvent{})
        if err != nil {
                logrus.WithFields(logrus.Fields{"module": logModule, "err": err}).Error("failed on subscribe NewBlockProposeEvent")
                return
@@ -117,7 +117,7 @@ func (m *Manager) blockProposeMsgBroadcastLoop() {
                                return
                        }
 
-                       ev, ok := obj.Data.(event.NewBlockProposeEvent)
+                       ev, ok := obj.Data.(event.NewProposedBlockEvent)
                        if !ok {
                                logrus.WithFields(logrus.Fields{"module": logModule}).Error("event type error")
                                continue