Zyre

#!/usr/bin/perl
use LWP::UserAgent;
use HTTP::Request::Common;

$ua = new LWP::UserAgent;
$ua->credentials ($hostname, "restms", "super", "super");
$baseuri = "http://localhost:8080/restms";

#   Create a named pipe and join on amq.direct to get console replies
$response = $ua->request (PUT "$baseuri/pipe/my.pipe/my.pipe\@amq.direct");
$response->code == 200 || die $response->status_line;

#   Send schema-request to console, as a sanity assertion
$request = HTTP::Request->new (POST => "$baseuri/amq.console\@amq.system");
$request->content ('<cml version="1.0"><schema-request/></cml>');
$request->header ("RestMS-reply-to" => "my.pipe");
$response = $ua->request ($request);

$response = $ua->request (GET "$baseuri/pipe/my.pipe/");
$response->code == 200 || die $response->status_line;

print $response->content."\n";

<?xml version="1.0"?>
<cml version="1.0" xmlns="http://www.openamq.org/schema/cml">
  <inspect-reply class="broker" object="0" status="ok">
    <field name="name">OpenAMQ 1.4a0</field>
    <field name="started">2008-12-26T21:12+01:00</field>
    <field name="locked">0</field>
    <field name="datamem">8817K</field>
    <field name="bucketmem">0K</field>
    <field name="messages">2</field>
    <field name="consumers">2</field>
    <field name="bindings">2</field>
    <field name="exchange">2</field>
    <field name="exchange">3</field>
    <field name="exchange">4</field>
    <field name="exchange">5</field>
    <field name="exchange">6</field>
    <field name="exchange">7</field>
    <field name="exchange">8</field>
    <field name="exchange">9</field>
    <field name="exchange">10</field>
    <field name="exchange">11</field>
    <field name="exchange">12</field>
    <field name="connection">13</field>
    <field name="config">1</field>
</inspect-reply>
</cml>

#!/usr/bin/perl
#   Zyre example showing how console access to an OpenAMQ server using
#   CML over RestMS.
#
#   Copyright (c) 1996-2007 iMatix Corporation
# 
#   This file is licensed under the GPL as follows:
# 
#   This program is free software; you can redistribute it and/or modify
#   it under the terms of the GNU General Public License as published by
#   the Free Software Foundation; either version 2 of the License, or (at
#   your option) any later version.
# 
#   This program is distributed in the hope that it will be useful, but
#   WITHOUT ANY WARRANTY; without even the implied warranty of
#   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
#   General Public License for more details.
# 
#   For information on alternative licensing for OEMs, please contact
#   iMatix Corporation.

use LWP::UserAgent;
use HTTP::Request::Common;

$verbose = 1;                           #   Display contents from Zyre
$hostname = $ARGV [0];
$hostname = "localhost" unless $hostname;
$baseuri = "http://$hostname/restms";

$ua = new LWP::UserAgent;
$ua->agent ('WebCML');
$ua->credentials ($hostname, "restms", "super", "super");
$ua->timeout (1);                       #   Keep things impatient

#   Create auto-named pipe and get pipe name from response
restms (PUT => "$baseuri/pipe");
if ($response->content =~ /name\s*=\s*"([^"]+)"/) {
    $pipe = $1;
}
else {
    die "Failed: malformed response for pipe\n";
}
#   Create a join on amq.direct to get console replies
restms (PUT => "$baseuri/pipe/$pipe/$pipe\@amq.direct");

#   Send schema-request to console, as a sanity assertion
cml_request ('<schema-request/>');

#   Inspect object zero, which is the OpenAMQ broker
cml_request ('<inspect-request object = "0" />');

#############################################################################

sub restms {
    my ($method, $uri) = @_;
    if (verbose) {
        print "$method => $uri\n";
    }
    $request = HTTP::Request->new ($method => $uri);
    $response = $ua->request ($request);
    check_ok ($response);
}

sub check_ok {
    my ($response) = @_;
    if (verbose) {
        carp ("Response=" . $response->code . " Content-type=" . $response->content_type);
        carp ($response->content) if $response->content_length;
    }
    if ($response->code != 200) {
        carp ("E: " . $response->status_line);
        carp ($response->content);
        exit (1);
    }
}

sub carp {
    my ($string) = @_;
    #   Prepare date and time variables
    ($sec, $min, $hour, $day, $month, $year) = localtime;
    $date = sprintf ("%04d-%02d-%02d", $year + 1900, $month + 1, $day);
    $time = sprintf ("%2d:%02d:%02d", $hour, $min, $sec);
    print "$date $time $string\n";
}

sub cml_request {
    ($_) = @_;

    #   Send CML formatted request to amq.console@amq.system
    $request = HTTP::Request->new (POST => "$baseuri/amq.console\@amq.system");
    $request->content ('<cml version="1.0">'.$_.'</cml>');
    $request->header ("RestMS-reply-to" => $pipe);
    $request->content_type ('text/xml');
    $response = $ua->request ($request);
    check_ok ($response);

    #   Read CML response
    restms (GET => "$baseuri/pipe/$pipe/");
}