diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-06-11 00:12:00 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-06-11 00:12:00 +0900 |
| commit | a90f93328f7813df74be2e9ec52f9f0e9866aca4 (patch) | |
| tree | 7c78c21e1f8929ed570fc703818507584c269263 | |
| parent | ca68e4237e2b67c495c82d406859f5c98a8430f6 (diff) | |
| download | aclog-a90f93328f7813df74be2e9ec52f9f0e9866aca4.tar.gz | |
collector: collector must not die even when received invalid message
| -rw-r--r-- | lib/collector/collector_proxy_connection.rb | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/lib/collector/collector_proxy_connection.rb b/lib/collector/collector_proxy_connection.rb index 7f0f558..1de2974 100644 --- a/lib/collector/collector_proxy_connection.rb +++ b/lib/collector/collector_proxy_connection.rb @@ -46,7 +46,11 @@ module Collector next end - parse_message(msg) + begin + parse_message(msg) + rescue + log(:error, "Failed to parse message: #{msg}") + end end end |