|
36 | 36 | expect(log_queue).to have_received(:<<).with([Logger::FATAL, "rdkafka: log line"]) |
37 | 37 | end |
38 | 38 |
|
| 39 | + it "should log fatal messages" do |
| 40 | + Rdkafka::Bindings::LogCallback.call(nil, 1, nil, "log line") |
| 41 | + expect(log_queue).to have_received(:<<).with([Logger::FATAL, "rdkafka: log line"]) |
| 42 | + end |
| 43 | + |
| 44 | + it "should log fatal messages" do |
| 45 | + Rdkafka::Bindings::LogCallback.call(nil, 2, nil, "log line") |
| 46 | + expect(log_queue).to have_received(:<<).with([Logger::FATAL, "rdkafka: log line"]) |
| 47 | + end |
| 48 | + |
39 | 49 | it "should log error messages" do |
40 | 50 | Rdkafka::Bindings::LogCallback.call(nil, 3, nil, "log line") |
41 | 51 | expect(log_queue).to have_received(:<<).with([Logger::ERROR, "rdkafka: log line"]) |
|
51 | 61 | expect(log_queue).to have_received(:<<).with([Logger::INFO, "rdkafka: log line"]) |
52 | 62 | end |
53 | 63 |
|
| 64 | + it "should log info messages" do |
| 65 | + Rdkafka::Bindings::LogCallback.call(nil, 6, nil, "log line") |
| 66 | + expect(log_queue).to have_received(:<<).with([Logger::INFO, "rdkafka: log line"]) |
| 67 | + end |
| 68 | + |
54 | 69 | it "should log debug messages" do |
55 | 70 | Rdkafka::Bindings::LogCallback.call(nil, 7, nil, "log line") |
56 | 71 | expect(log_queue).to have_received(:<<).with([Logger::DEBUG, "rdkafka: log line"]) |
|
0 commit comments