1 package Catalyst::Test::MessageDriven;
7 $ENV{CATALYST_ENGINE} = 'Test::MessageDriven';
12 Catalyst::Test::MessageDriven - test message-driven Catalyst apps
16 Derived from Catalyst::Test, this module provides a way to run tests
17 against message-driven Catalyst applications - those with
18 Catalyst::Controller::MessageDriven-based controllers, and expect to
19 run with Catalyst::Engine::Stomp.
23 BEGIN { use_ok 'Catalyst::Test::MessageDriven', 'SomeApp' };
25 my $req = '... some message text ...';
26 my $queue = 'somequeue';
27 my $res = request($queue, $req);
32 =head2 request(queue, message)
34 This function accepts a queue and a message, and runs the request in
35 that context. Returns a response object.
39 Some test wrappers - successful / error message conditions?
43 my $build_exports = sub {
44 my ($self, $meth, $args, $defaults) = @_;
47 my $class = $args->{class};
50 $request = sub { Catalyst::Exception->throw("Must specify a test app: use Catalyst::Test::MessageDriven 'TestApp'") };
53 unless (Class::MOP::is_class_loaded($class)) {
54 Class::MOP::load_class($class);
58 my $app = $class->run();
59 $request = sub { message_driven_request( $app, @_ ) };
68 my $import = Sub::Exporter::build_exporter({
69 groups => [ all => $build_exports ],
74 my ($self, $class) = @_;
75 $import->($self, '-all' => { class => $class });
80 sub message_driven_request {
81 my ($app, $path, $req_message) = @_;
82 my $url = "message://localhost:61613/$path";
84 my $request = HTTP::Request->new( POST => $url );
85 $request->content($req_message);
86 $request->content_length(length $req_message);
87 $request->content_type('application/octet-stream');
90 $app->handle_request($request, \$response);
95 package # Hide from PAUSE
96 Catalyst::Engine::Test::MessageDriven;
97 use base 'Catalyst::Engine::Embeddable';
100 my ($self, $app) = @_;