AnyEvent-MQTT

 view release on metacpan or  search on metacpan

misc/t/001-ping-with-payload.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" : "send", "cvname" : "pingresp", "response" : "pingresp",
    "arguments" : { "message_type" : 12, "remaining" : "data" } },
  { "action" : "wait", "for" : "pingresp",

misc/t/01-connect.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" } ],
  "log" : [ "> Connect/at-most-once MQIsdp/3/%testname% ",
            "< ConnAck/at-most-once Connection Accepted ",
            "> Disconnect/at-most-once" ] }

misc/t/02-pub-qos0-sub-qos0.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", "result" : "0", "cvname" : "subscribe-qos0" },
  { "action" : "publish", "arguments" : { "message" : "just testing" } },

misc/t/02-pub-qos0-sub-qos1.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" : 1 },

misc/t/02-pub-qos0-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 },

misc/t/03-pub-qos1-sub-qos0.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", "result" : "0", "cvname" : "subscribe-qos0" },
  {

misc/t/03-pub-qos1-sub-qos1.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" : 1 },

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 },

misc/t/04-pub-qos2-sub-qos0.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", "result" : "0", "cvname" : "subscribe-qos0" },
  {

misc/t/04-pub-qos2-sub-qos1.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" : 1 },
    "result" : "1", "cvname" : "subscribe-qos1" },

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" },

misc/t/05-pub-retain-qos0-pub-qos0.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",

misc/t/05-pub-retain-qos0-pub-qos1.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",

misc/t/05-pub-retain-qos0-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",

misc/t/06-pub-retain-qos1-pub-qos0.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",

misc/t/06-pub-retain-qos1-pub-qos1.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",

misc/t/06-pub-retain-qos1-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",

misc/t/07-pub-retain-qos2-pub-qos0.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",

misc/t/07-pub-retain-qos2-pub-qos1.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",

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",

misc/t/09-ping.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" : "send", "cvname" : "pingresp", "response" : "pingresp",
    "arguments" : { "message_type" : 12 } },
  { "action" : "wait", "for" : "pingresp",



( run in 0.342 second using v1.01-cache-2.11-cpan-87723dcf8b7 )