lib/rrj/janus/transactions/session.rb in ruby_rabbitmq_janus-3.0.0.pre.336 vs lib/rrj/janus/transactions/session.rb in ruby_rabbitmq_janus-3.0.0.pre.351

@@ -14,31 +14,25 @@
         # @param [Fixnum] session
         #   Use a session identifier for created message
         def initialize(exclusive, session)
           super(session)
           @exclusive = exclusive
-        rescue
-          raise Errors::Janus::TransactionSessions::Initialize
         end
 
         # Opening a short transaction with rabbitmq and close when is ending
         #
         # @yield Send a message to Janus
         def connect
           rabbit.transaction_short do
             choose_queue
             yield
           end
-        rescue
-          raise Errors::Janus::TransactionSessions::Connect
         end
 
         def publish_message(type, options = {})
           msg = Janus::Messages::Standard.new(type, opts.merge!(options))
           response = read_response(publisher.publish(msg))
           Janus::Responses::Standard.new(response)
-        rescue
-          raise Errors::Janus::TransactionSessions::PublishMessage
         end
 
         private
 
         def opts