lib/rrj/errors/rabbit/publish/publisher.rb in ruby_rabbitmq_janus-2.2.0 vs lib/rrj/errors/rabbit/publish/publisher.rb in ruby_rabbitmq_janus-2.2.1.pre.180

@@ -1,7 +1,9 @@
 # frozen_string_literal: true
 
+# :reek:IrresponsibleModule
+#
 module RubyRabbitmqJanus
   module Errors
     module Rabbit
       # Define a super class for all errors in Rabbit::Publisher::Publish
       class BasePublish < BaseErrorPublisher
@@ -20,9 +22,15 @@
 
         # Error for Rabbit::Publisher::Publish#publish
         class Publish < RubyRabbitmqJanus::Errors::Rabbit::BasePublish
           def initialize
             super 'Error for publish message'
+          end
+        end
+
+        class Testcorrelation < RubyRabbitmqJanus::Errors::Rabbit::BasePublish
+          def initialize(message, propertie)
+            super "Response correlation ID mismatch (#{message} != #{propertie})", :fatal
           end
         end
       end
     end
   end