AnyEvent-MQTT
view release on metacpan or search on metacpan
misc/t/07-pub-retain-qos2-pub-qos2.t view on Meta::CPAN
#!/usr/bin/perl
use warnings;
use strict;
use FindBin;
use lib $FindBin::Bin;
use Tester;
Tester->run(\*DATA);
__DATA__
{
"stream" :
[
{ "action" : "connect" },
{
"action" : "publish",
"arguments" : { "qos" : 2, "message" : "retained", "retain" : 1 }
},
{
"action" : "publish",
"arguments" : { "qos" : 2, "message" : "not retained" }
},
{ "action" : "subscribe", "result" : "0", "cvname" : "subscribe-qos0" },
{
"action" : "wait", "for" : "subscribe-qos0",
"result" : { "topic" : "%topicpid%", "message" : "retained" }
},
{ "action" : "unsubscribe", "result" : 1 },
{
"action" : "publish",
"arguments" : { "qos" : 0, "message" : "", "retain" : 1 }
},
{ "action" : "subscribe", "result" : "0", "cvname" : "subscribe-qos1" },
{ "action" : "timeout", "timeout" : 0.5, "cvname" : "subscribe-qos1" },
{
"action" : "wait", "for" : "subscribe-qos1", "result" : "timeout"
}
],
"log" :
[
"> Connect/at-most-once MQIsdp/3/%testname% ",
"< ConnAck/at-most-once Connection Accepted ",
"> Publish/exactly-once,retain %topicpid%/1 \n 72 65 74 61 69 6e 65 64 retained",
"< PubRec/at-most-once 1 ",
"> PubRel/at-least-once 1 ",
"< PubComp/at-most-once 1 ",
"> Publish/exactly-once %topicpid%/2 \n 6e 6f 74 20 72 65 74 61 69 6e 65 64 not retained",
"< PubRec/at-most-once 2 ",
"> PubRel/at-least-once 2 ",
"< PubComp/at-most-once 2 ",
"> Subscribe/at-least-once 3 %topicpid%/at-most-once ",
"< SubAck/at-most-once 3/at-most-once ",
"< Publish/at-most-once,retain %topicpid% \n 72 65 74 61 69 6e 65 64 retained",
"> Unsubscribe/at-least-once 4 %topicpid% ",
"< UnsubAck/at-most-once 4 ",
"> Publish/at-most-once,retain %topicpid% ",
"> Subscribe/at-least-once 5 %topicpid%/at-most-once ",
"< SubAck/at-most-once 5/at-most-once ",
"> Disconnect/at-most-once"
]
}
( run in 1.967 second using v1.01-cache-2.11-cpan-364913b4093 )