vendor/bundle/ruby/1.8/gems/activemessaging-0.9.0/lib/activemessaging/adapters/reliable_msg.rb
# called after a message is successfully received and processed
called after a message is successfully received and processed
called after a message is successfully received and processed
def unreceive message, headers={}
        begin
          message.transaction[:qm].abort(message.transaction[:tid])
        rescue Object=>ex
          puts "unreceive failed: #{ex.message}"
        ensure
          Thread.current[::ReliableMsg::Client::THREAD_CURRENT_TX] = nil
        end
      end
def unreceive message , headers = { } begin message . transaction [ :qm ] . abort ( message . transaction [ :tid ] ) rescue Object => ex puts "unreceive failed: #{ex.message}" ensure Thread . current [ :: ReliableMsg :: Client :: THREAD_CURRENT_TX ] = nil end end
called after a message is successfully received and processed
called after a message is successfully received and processed
message
headers