view release on metacpan or  search on metacpan

misc/t/03-pub-qos1-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" : 1, "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/at-least-once %topicpid%/2 \n  6a 75 73 74 20 74 65 73 74 69 6e 67              just testing",
  [
   {
    "re" : "< PubAck/",
    "diag" : "minor deviation from specified order",
    "log" :
    [
     "< PubAck/at-most-once 2 ",
     "< Publish/at-least-once %topicpid%/1 \n  6a 75 73 74 20 74 65 73 74 69 6e 67              just testing",
     "> PubAck/at-most-once 1 ",
     "> Disconnect/at-most-once"
    ]
   },
   {
    "log" :
    [
     "< Publish/at-least-once %topicpid%/1 \n  6a 75 73 74 20 74 65 73 74 69 6e 67              just testing",
     "> PubAck/at-most-once 1 ",
     "< PubAck/at-most-once 2 ",
     "> Disconnect/at-most-once"
    ]
   }
  ]
 ]
}