Skip to content
Snippets Groups Projects
Commit 4aa074d2 authored by Richard T. Carback III's avatar Richard T. Carback III
Browse files

Put message handler in the init function

parent c7ad9796
No related branches found
No related tags found
3 merge requests!510Release,!209Modify network stack to not require network,!207WIP: Client Restructure
...@@ -113,6 +113,10 @@ func NewClient(params Params, comms *commClient.Comms, session storage.Session, ...@@ -113,6 +113,10 @@ func NewClient(params Params, comms *commClient.Comms, session storage.Session,
c.verboseRounds = NewRoundTracker() c.verboseRounds = NewRoundTracker()
} }
// Set up Message Handler
c.Handler = message.NewHandler(c.param.Message, c.session.GetKV(),
c.events, c.session.GetReceptionID())
return c, nil return c, nil
} }
...@@ -160,10 +164,6 @@ func (c *client) Connect(ndf *ndf.NetworkDefinition) error { ...@@ -160,10 +164,6 @@ func (c *client) Connect(ndf *ndf.NetworkDefinition) error {
c.Retriever = rounds.NewRetriever( c.Retriever = rounds.NewRetriever(
c.param.Historical, c.comms, c.Sender, c.events) c.param.Historical, c.comms, c.Sender, c.events)
// Set up Message Handler
c.Handler = message.NewHandler(c.param.Message, c.session.GetKV(),
c.events, c.session.GetReceptionID())
// Set up round handler // Set up round handler
c.Pickup = pickup.NewPickup( c.Pickup = pickup.NewPickup(
c.param.Pickup, c.Handler.GetMessageReceptionChannel(), c.Sender, c.param.Pickup, c.Handler.GetMessageReceptionChannel(), c.Sender,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment