AnyEvent-MQTT

 view release on metacpan or  search on metacpan

misc/t/04-pub-qos2-sub-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" : "subscribe","arguments" : { "qos" : 2 },
    "result" : "2", "cvname" : "subscribe-qos2" },
  {
   "action" : "publish", "arguments" : { "qos" : 2, "message" : "just testing" }
  },
  {
   "action" : "wait", "for" : "subscribe-qos2",
   "result" : { "topic" : "%topicpid%", "message" : "just testing" }
  }
 ],
 "log" :
 [
  "> Connect/at-most-once MQIsdp/3/%testname% ",
  "< ConnAck/at-most-once Connection Accepted ",
  "> Subscribe/at-least-once 1 %topicpid%/exactly-once ",
  "< SubAck/at-most-once 1/exactly-once ",
  "> Publish/exactly-once %topicpid%/2 \n  6a 75 73 74 20 74 65 73 74 69 6e 67              just testing",
  "< PubRec/at-most-once 2 ",
  "> PubRel/at-least-once 2 ",
  "< PubComp/at-most-once 2 ",
  "< Publish/exactly-once %topicpid%/1 \n  6a 75 73 74 20 74 65 73 74 69 6e 67              just testing",
  "> PubRec/at-most-once 1 ",
  "< PubRel/at-least-once 1 ",
  "> PubComp/at-most-once 1 ",
  "> Disconnect/at-most-once"
 ]
}



( run in 1.189 second using v1.01-cache-2.11-cpan-6aa56a78535 )