Contents

require 'test_helper'
require 'active_support/log_subscriber/test_helper'
require 'cassandra_object/log_subscriber'

class CassandraObject::LogSubscriberTest < CassandraObject::TestCase
  include ActiveSupport::LogSubscriber::TestHelper

  def setup
    super

    CassandraObject::LogSubscriber.attach_to :cassandra_object
  end

  def test_cql_notification
    Issue.adapter.execute 'SELECT * FROM Issues'

    wait

    assert_match 'SELECT * FROM Issues', @logger.logged(:debug)[0]
  end

  def test_initializes_runtime
    Thread.new { assert_equal 0, CassandraObject::LogSubscriber.runtime }.join
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
extendi-cassandra_object-1.0.7	test/unit/log_subscriber_test.rb
extendi-cassandra_object-1.0.6	test/unit/log_subscriber_test.rb
extendi-cassandra_object-1.0.5	test/unit/log_subscriber_test.rb
extendi-cassandra_object-1.0.4	test/unit/log_subscriber_test.rb
extendi-cassandra_object-1.0.1	test/unit/log_subscriber_test.rb
extendi-cassandra_object-1.0.0	test/unit/log_subscriber_test.rb