|
|
@@ -46,6 +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(); });
|
|
|
$rabbit = new rabbit_async($config->{rabbit}, sub
|
|
|
{
|
|
|
$rabbit->listen_queue($config->{queue}, $config->{bind}, \&incoming_message);
|
|
|
@@ -117,7 +118,7 @@ sub incoming_message
|
|
|
eval {
|
|
|
$sub->($body,$m);
|
|
|
};
|
|
|
-
|
|
|
+
|
|
|
if ($@)
|
|
|
{
|
|
|
$log->error($@);
|
|
|
@@ -214,7 +215,7 @@ sub terminate
|
|
|
exit(0);
|
|
|
})->catch(sub
|
|
|
{
|
|
|
- say Dumper @_;
|
|
|
+ $log->error(@_);
|
|
|
});
|
|
|
}
|
|
|
|
|
|
@@ -263,7 +264,10 @@ sub notify
|
|
|
|
|
|
$params->{reply_to_message_id} = $rest->{msgid} if $rest->{msgid};
|
|
|
|
|
|
- return request("sendMessage", $params);
|
|
|
+ return request("sendMessage", $params)->catch(sub
|
|
|
+ {
|
|
|
+ $log->error(@_);
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
sub refpath
|