1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#!/usr/bin/env perl
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
use strict;
use warnings;
use Getopt::Std;
use qpid_proton;
$Getopt::Std::STANDARD_HELP_VERSION = 1;
sub VERSION_MESSAGE() {
}
sub HELP_MESSAGE() {
print "Usage: send.pl [OPTIONS] -a <ADDRESS>\n";
print "Options:\n";
print "\t-s - the message subject\n";
print "\t-C - the message content\n";
print "\t<ADDRESS> - amqp://<domain>[/<name>]\n";
print "\t-h - this message\n";
exit;
}
my %options = ();
getopts("a:C:s:h:", \%options) or HELP_MESSAGE();
my $address = $options{a} || "amqp://0.0.0.0";
my $subject = $options{s} || localtime(time);
my $content = $options{C} || "";
my $msg = new qpid::proton::Message();
my $messenger = new qpid::proton::Messenger();
$messenger->start();
my @messages = @ARGV;
@messages = ("This is a test. " . localtime(time)) unless $messages[0];
foreach (@messages)
{
$msg->set_address($address);
$msg->set_subject($subject);
$msg->set_body($content);
# try a few different body types
my $body_type = int(rand(6));
$msg->set_property("sent", "" . localtime(time));
$msg->get_instructions->{"fold"} = "yes";
$msg->get_instructions->{"spindle"} = "no";
$msg->get_instructions->{"mutilate"} = "no";
$msg->get_annotations->{"version"} = 1.0;
$msg->get_annotations->{"pill"} = "RED";
SWITCH: {
$body_type == 0 && do { $msg->set_body("It is now " . localtime(time));};
$body_type == 1 && do { $msg->set_body(rand(65536)); };
$body_type == 2 && do { $msg->set_body(int(rand(2)), qpid::proton::BOOL); };
$body_type == 3 && do { $msg->set_body({"foo" => "bar"}); };
$body_type == 4 && do { $msg->set_body([4, [1, 2, 3.1, 3.4E-5], 8, 15, 16, 23, 42]); };
$body_type == 5 && do { $msg->set_body(int(rand(65535))); }
}
$messenger->put($msg);
print "Sent: " . $msg->get_body . " [CONTENT TYPE: " . $msg->get_body_type . "]\n";
}
$messenger->send();
$messenger->stop();
die $@ if ($@);
|
