Skip to content

Commit 09685b4

Browse files
app: integration
1 parent 05c6ba5 commit 09685b4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

dmq-node/app/Main.hs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,8 @@ runDMQ commandLineConfig = do
102102
let sigSize _ = 0 -- TODO
103103
maxMsgs = 1000 -- TODO: make this negotiated in the handshake?
104104
mempoolReader = Mempool.getReader sigId sigSize (mempool nodeKernel)
105-
mempoolWriter = Mempool.getWriter sigId (const ()) (\_ _ -> pure True) (mempool nodeKernel)
105+
StakePools { poolValidationCtx } = stakePools nodeKernel
106+
mempoolWriter = Mempool.getWriter sigId poolValidationCtx (\_ _ -> pure True) (mempool nodeKernel)
106107
in NtC.ntcApps mempoolReader mempoolWriter maxMsgs
107108
(NtC.dmqCodecs encodeReject decodeReject)
108109
dmqDiffusionArguments =

0 commit comments

Comments
 (0)