mackuba.eu
+7
-2
app/firehose_stream.rb
+7
-2
app/firehose_stream.rb
···
119
119
120
120
return unless op.action == :create
121
121
122
-
if op.raw_record.nil?
123
-
puts "Error: missing expected record data in operation: #{op.uri} (#{msg.seq})"
122
+
begin
123
+
if op.raw_record.nil?
124
+
puts "Error: missing expected record data in operation: #{op.uri} (#{msg.seq})"
125
+
return
126
+
end
127
+
rescue CBOR::UnpackError => e
128
+
puts "Error: couldn't decode record data for #{op.uri} (#{msg.seq}): #{e}"
124
129
return
125
130
end
126
131