lib/logstash/inputs/couchdb_changes.rb in logstash-input-couchdb_changes-3.1.0 vs lib/logstash/inputs/couchdb_changes.rb in logstash-input-couchdb_changes-3.1.1
- old
+ new
@@ -175,10 +175,10 @@
next if changes.chomp.empty?
if event = build_event(changes)
@logger.debug("event", :event => event.to_hash_with_metadata) if @logger.debug?
decorate(event)
queue << event
- @sequence = event['@metadata']['seq']
+ @sequence = event.get("[@metadata][seq]")
@sequencedb.write(@sequence.to_s)
end
end
end
end