X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FCatalyst%2FEngine%2FStomp.pm;h=e4373615a616bca5c7fed2def435893f18cd8264;hb=d7c364aac5ffb253fd9db5f3191eca30a1edb8c8;hp=f2b588ffffb89cdfbbe15a73a1f85a5261152f7f;hpb=939aaa4607adfef8ac543476891d0117c46cdfa9;p=catagits%2FCatalyst-Engine-STOMP.git diff --git a/lib/Catalyst/Engine/Stomp.pm b/lib/Catalyst/Engine/Stomp.pm index f2b588f..e437361 100644 --- a/lib/Catalyst/Engine/Stomp.pm +++ b/lib/Catalyst/Engine/Stomp.pm @@ -27,8 +27,11 @@ Catalyst::Engine::Stomp - write message handling apps with Catalyst. MyApp->config->{Engine::Stomp} = { - hostname => '127.0.0.1', - port => 61613, + hostname => '127.0.0.1', + port => 61613, + subscribe_header => { + transformation => 'jms-to-json', + } }; MyApp->run(); @@ -197,7 +200,6 @@ sub handle_stomp_message { # ack the message off the queue now we've replied / processed $self->connection->ack( { frame => $frame } ); } - =head2 handle_stomp_error Log any Stomp error frames we receive. @@ -213,3 +215,11 @@ sub handle_stomp_error { __PACKAGE__->meta->make_immutable; +=head1 CONFIGURATION + +=head2 subscribe_header + +Add additional header key/value pairs to the subscribe message sent to the +message broker. + +=cut