Skip to content

Commit

Permalink
Incr coverage
Browse files Browse the repository at this point in the history
  • Loading branch information
attdona committed Aug 22, 2024
1 parent 5b66b0f commit 1d717fe
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 8 deletions.
4 changes: 0 additions & 4 deletions src/Rembus.jl
Original file line number Diff line number Diff line change
Expand Up @@ -1684,10 +1684,6 @@ end

function pkfile(name)
cfgdir = rembus_dir()
if !isdir(cfgdir)
mkpath(cfgdir)
end

return joinpath(cfgdir, name)
end

Expand Down
3 changes: 0 additions & 3 deletions src/broker.jl
Original file line number Diff line number Diff line change
Expand Up @@ -509,9 +509,6 @@ function register(router, msg)
reason = "name $(msg.cid) not available for registration"
else
kdir = keys_dir(router)
if !isdir(kdir)
mkdir(kdir)
end

save_pubkey(router, msg.cid, msg.pubkey)
if !(msg.cid in router.component_owner.component)
Expand Down
2 changes: 1 addition & 1 deletion test/broker_plugin/test_publish_interceptor.jl
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ function publish_interceptor(ctx, component, msg)
publish(ctx.subscriber, "direct_message", 999)

# publish using router
router = Rembus.get_router()
router = Rembus.get_router("caronte_test")
publish(router, "some_topic", "some_data")

try
Expand Down

0 comments on commit 1d717fe

Please sign in to comment.