Contents

# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/outputs/mongodb"

RSpec::Matchers.define :have_received do |event|
  match do |subject|
    client     = subject.instance_variable_get("@db")
    collection = subject.instance_variable_get("@collection")
    client["#{collection}"].find("@timestamp" => event["@timestamp"].to_json).count > 0
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-output-mongodb-2.0.2	spec/spec_helper.rb
logstash-output-mongodb-2.0.1	spec/spec_helper.rb
logstash-output-mongodb-1.0.0	spec/spec_helper.rb