Class: Qpid::Proton::Reactor::InternalTransactionHandler

Inherits:

Handler::OutgoingMessageHandler

• Object
• BaseHandler
• Handler::OutgoingMessageHandler
• Qpid::Proton::Reactor::InternalTransactionHandler

Defined in:

lib/reactor/container.rb

Instance Method Summary

• #initialize ⇒ InternalTransactionHandler constructor

  A new instance of InternalTransactionHandler.

• #on_settled(event) ⇒ Object

Methods inherited from Handler::OutgoingMessageHandler

#on_accepted, #on_delivery, #on_link_flow, #on_rejected, #on_released, #on_sendable

Methods inherited from BaseHandler

#on_unhandled

Constructor Details

#initialize ⇒ InternalTransactionHandler

Returns a new instance of InternalTransactionHandler.

# File 'lib/reactor/container.rb', line 25

def initialize
  super
end

Instance Method Details

#on_settled(event) ⇒ Object

# File 'lib/reactor/container.rb', line 29

def on_settled(event)
  if event.delivery.respond_to? :transaction
    event.transaction = event.delivery.transaction
    event.delivery.transaction.handle_outcome(event)
  end
end