|
|
@@ -46,7 +46,7 @@ Mojo::IOLoop->next_tick(sub
|
|
|
$int = AnyEvent->signal(signal => "INT", cb => \&terminate);
|
|
|
$hup = AnyEvent->signal(signal => "HUP", cb => \&terminate);
|
|
|
|
|
|
- $config->{rabbit}->{on_error} = sub { $log->error(@_); terminate() };
|
|
|
+ $config->{rabbit}->{on_error} = sub { $log->error("[rabbit]".@_); terminate() };
|
|
|
$rabbit = new rabbit_async($config->{rabbit}, sub
|
|
|
{
|
|
|
$rabbit->listen_queue($config->{queue}, $config->{bind}, \&incoming_message);
|