Update to start Broker.

shimmeringbee · May 25, 2021 · f3b4c8f · f3b4c8f
1 parent 5071884
commit f3b4c8f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/go.mod b/go.mod
@@ -6,7 +6,7 @@ require (
 	github.com/shimmeringbee/bytecodec v0.0.0-20210228205504-1e9e0677347b
 	github.com/shimmeringbee/logwrap v0.0.0-20210228205504-ec4498cd3a41
 	github.com/shimmeringbee/retry v0.0.0-20210228205505-2704f9c1c8a2
-	github.com/shimmeringbee/unpi v0.0.0-20210228205505-862f12969c1f
+	github.com/shimmeringbee/unpi v0.0.0-20210525151328-7ede275a1033
 	github.com/shimmeringbee/zigbee v0.0.0-20210427191220-76676a734066
 	github.com/stretchr/testify v1.7.0
 	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect

diff --git a/go.sum b/go.sum
@@ -25,6 +25,8 @@ github.com/shimmeringbee/unpi v0.0.0-20210111171128-10074b5edd8f h1:rLLdpe771s3I
 github.com/shimmeringbee/unpi v0.0.0-20210111171128-10074b5edd8f/go.mod h1:hOrncW6hd26Z18eayp99i7hNKj0aHtUx1SxXT49aEsk=
 github.com/shimmeringbee/unpi v0.0.0-20210228205505-862f12969c1f h1:jZXsUdeA92pXoiuOOEUiuM3cbE6BFpih7y6Hb05D+H0=
 github.com/shimmeringbee/unpi v0.0.0-20210228205505-862f12969c1f/go.mod h1:hOrncW6hd26Z18eayp99i7hNKj0aHtUx1SxXT49aEsk=
+github.com/shimmeringbee/unpi v0.0.0-20210525151328-7ede275a1033 h1:PQGdXelNwwcQH58S90MR0xA3GnikCnzt+xpDw0P4qxM=
+github.com/shimmeringbee/unpi v0.0.0-20210525151328-7ede275a1033/go.mod h1:hOrncW6hd26Z18eayp99i7hNKj0aHtUx1SxXT49aEsk=
 github.com/shimmeringbee/zigbee v0.0.0-20210113202023-651b51432b13 h1:Zlu+99+PDDvkWAJwy2SvtCb+NKuVRAJ7fVBZ9J3gm6o=
 github.com/shimmeringbee/zigbee v0.0.0-20210113202023-651b51432b13/go.mod h1:GMA6rVpzvUK16cZwi8uW11JUTx8xUGOk5DbkXYWvm/8=
 github.com/shimmeringbee/zigbee v0.0.0-20210113204558-b0b1b8711592 h1:iD4w6TAkFqNoFk2WSUnjjD5kuFL4pf7ZnRsyykSKVIA=

diff --git a/zstack.go b/zstack.go
@@ -76,6 +76,7 @@ func New(uart io.ReadWriter, nodeTable *NodeTable) *ZStack {
 	registerMessages(ml)
 
 	znp := broker.NewBroker(uart, uart, ml)
+	znp.Start()
 
 	transactionIDs := make(chan uint8, DefaultInflightTransactions)