extends 'Catalyst::Engine::Embeddable';
-our $VERSION = '0.05';
+our $VERSION = '0.06';
has connection => (is => 'rw', isa => 'Net::Stomp');
has conn_desc => (is => 'rw', isa => 'Str');
# connect up
my %template = %{$app->config->{'Engine::Stomp'}};
+ my $subscrine_headers = $template{subscribe_headers} || {};
+ die("subscribe_headers config for Engine::Stomp must be a hashref!\n")
+ if (ref($subscribe_headers) ne 'HASH');
+
$self->connection(Net::Stomp->new(\%template));
$self->connection->connect();
$self->conn_desc($template{hostname}.':'.$template{port});
foreach my $queue (@queues) {
my $queue_name = "/queue/$queue";
$self->connection->subscribe({
- destination => $queue_name,
- ack => 'client'
- });
+ %$subscribe_headers,
+ destination => $queue_name,
+ ack => 'client',
+ });
}
# enter loop...