spec/backends/db_spec.rb in deimos-ruby-1.3.0.pre.beta4 vs spec/backends/db_spec.rb in deimos-ruby-1.3.0.pre.beta5
- old
+ new
@@ -2,9 +2,14 @@
each_db_config(Deimos::Backends::Db) do
include_context 'with publish_backend'
it 'should save to the database' do
+ expect(Deimos.config.metrics).to receive(:increment).with(
+ 'db_producer.insert',
+ tags: %w(topic:my-topic),
+ by: 3
+ )
described_class.publish(producer_class: MyProducer, messages: messages)
records = Deimos::KafkaMessage.all
expect(records.size).to eq(3)
expect(records[0].attributes.to_h).to include(
'message' => '{"foo"=>1}',