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