class Qpid::Proton::Handler::MessagingHandler

@overload initialize(opts)

Create a {MessagingHandler} with options +opts+
@option opts [Integer] :prefetch (10)
 The number of messages to  fetch in advance, 0 disables prefetch.
@option opts [Boolean] :auto_accept  (true)
 If true, incoming messages are accepted automatically after {#on_message}.
 If false, the application can accept, reject or release the message
 by calling methods on {Delivery} when the message has been processed.
@option opts [Boolean] :auto_settle (true) If true, outgoing
 messages are settled automatically when the remote peer settles. If false,
 the application must call {Delivery#settle} explicitly.
@option opts [Boolean] :auto_open (true)
 If true, incoming connections are  opened automatically.
 If false, the application must call {Connection#open} to open incoming connections.
@option opts [Boolean] :auto_close (true)
 If true, respond to a remote close automatically with a local close.
 If false, the application must call {Connection#close} to finish closing connections.
@option opts [Boolean] :peer_close_is_error (false)
 If true, and the remote peer closes the connection without an error condition,
 the set the local error condition {Condition}("error", "unexpected peer close")

@overload initialize(prefetch=10, auto_accept=true, auto_settle=true, peer_close_is_error=false) @deprecated use +initialize(opts)+ overload

# File lib/handler/messaging_handler.rb, line 53
def initialize(*args)
  deprecated MessagingHandler, Qpid::Proton::MessagingHandler
  @options = {}
  if args.size == 1 && args[0].is_a?(Hash)
    @options.replace(args[0])
  else                      # Fill options from deprecated fixed arguments
    [:prefetch, :auto_accept, :auto_settle, :peer_close_is_error].each do |k|
      opts[k] = args.shift unless args.empty?
    end
  end
  # NOTE: the options are processed by {Handler::Adapater}
end

@private

# File lib/handler/messaging_handler.rb, line 27
def proton_adapter_class() Handler::ReactorMessagingAdapter; end