fix(gateway): fix coap test case error
This commit is contained in:
parent
81a86e3202
commit
bc12899ef8
|
@ -333,14 +333,14 @@ t_on_offline_event(_) ->
|
||||||
emqx_hooks:add('client.connected', {emqx_sys, on_client_connected, []}, 1000),
|
emqx_hooks:add('client.connected', {emqx_sys, on_client_connected, []}, 1000),
|
||||||
emqx_hooks:add('client.disconnected', {emqx_sys, on_client_disconnected, []}, 1000),
|
emqx_hooks:add('client.disconnected', {emqx_sys, on_client_disconnected, []}, 1000),
|
||||||
|
|
||||||
ConnectedSub = <<"$SYS/brokers/+/gateways/coap/clients/+/connected">>,
|
ConnectedSub = <<"$SYS/brokers/+/gateway/coap/clients/+/connected">>,
|
||||||
emqx_broker:subscribe(ConnectedSub),
|
emqx_broker:subscribe(ConnectedSub),
|
||||||
timer:sleep(100),
|
timer:sleep(100),
|
||||||
|
|
||||||
Token = connection(Channel),
|
Token = connection(Channel),
|
||||||
?assertMatch(#message{}, receive_deliver(500)),
|
?assertMatch(#message{}, receive_deliver(500)),
|
||||||
|
|
||||||
DisconnectedSub = <<"$SYS/brokers/+/gateways/coap/clients/+/disconnected">>,
|
DisconnectedSub = <<"$SYS/brokers/+/gateway/coap/clients/+/disconnected">>,
|
||||||
emqx_broker:subscribe(DisconnectedSub),
|
emqx_broker:subscribe(DisconnectedSub),
|
||||||
timer:sleep(100),
|
timer:sleep(100),
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue