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
|
use strict;
use Test::More (tests => 11);
use Data::Dumper;
BEGIN
{
use_ok("POE::Filter::Stomp");
}
my $body = join(
"\n",
("0123456789abcdefghijklmnopqrstuvwxyz0123456789abcdefghijklmnopqrstuvwxyz") x 10
);
my $length = length($body);
my $message = join(
"\n",
"MESSAGE",
"destination: /queue/foo",
"content-length: " . $length,
"",
"$body\000",
);
my @parts = split_message($message . "\n" . $message);
my $filter = POE::Filter::Stomp->new;
$filter->get_one_start(\@parts);
for(1..2) {
my @buffers;
my $arrayref = $filter->get_one;
my $frame = $arrayref->[0];
ok($frame);
isa_ok($frame, "Net::Stomp::Frame");
is( $frame->body, $body );
@buffers = $filter->put([$frame]);
for my $buffer (@buffers) {
$filter->get_one_start($buffer);
$arrayref = $filter->get_one;
$frame = $arrayref->[0];
ok($frame);
isa_ok($frame, "Net::Stomp::Frame")
}
}
sub split_message
{
my $message = shift;
my $len = length($message);
my @ret;
while ($len > 0) {
push @ret, substr($message, 0, int(rand($len) + 1), '');
$len = length($message);
}
return @ret;
}
|
