PROTON-781: Added IncomingMessageHandler to the Ruby reactive APIs.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/e165313d Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/e165313d Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/e165313d Branch: refs/heads/PROTON-781-ruby-reactor-apis Commit: e165313d7cf85a6d5fdaf5cd3072a0f56c337df5 Parents: afdef67 Author: Darryl L. Pierce <mcpie...@gmail.com> Authored: Thu Feb 26 09:23:00 2015 -0500 Committer: Darryl L. Pierce <mcpie...@gmail.com> Committed: Thu Jun 18 09:27:20 2015 -0400 ---------------------------------------------------------------------- proton-c/bindings/ruby/lib/core/exceptions.rb | 10 +++ .../lib/handler/incoming_message_handler.rb | 74 ++++++++++++++++++++ proton-c/bindings/ruby/lib/qpid_proton.rb | 1 + 3 files changed, 85 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e165313d/proton-c/bindings/ruby/lib/core/exceptions.rb ---------------------------------------------------------------------- diff --git a/proton-c/bindings/ruby/lib/core/exceptions.rb b/proton-c/bindings/ruby/lib/core/exceptions.rb index 94d2957..75d6552 100644 --- a/proton-c/bindings/ruby/lib/core/exceptions.rb +++ b/proton-c/bindings/ruby/lib/core/exceptions.rb @@ -111,6 +111,16 @@ module Qpid class SSLUnavailableError < SSLError end + # Raised when a message is rejected. + # + class Reject < ProtonError + end + + # Raised when a message is released. + # + class Release < ProtonError + end + end end http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e165313d/proton-c/bindings/ruby/lib/handler/incoming_message_handler.rb ---------------------------------------------------------------------- diff --git a/proton-c/bindings/ruby/lib/handler/incoming_message_handler.rb b/proton-c/bindings/ruby/lib/handler/incoming_message_handler.rb new file mode 100644 index 0000000..ced84a2 --- /dev/null +++ b/proton-c/bindings/ruby/lib/handler/incoming_message_handler.rb @@ -0,0 +1,74 @@ +#-- +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +#++ + +module Qpid::Proton::Handler + + # A utility for simpler and more intuitive handling of delivery events + # related to incoming messages. + # + class IncomingMessageHandler < Qpid::Proton::BaseHandler + + include Acking + + def initialize(auto_accept = true, delegate = nil) + @delegate = delegate + @auto_accept = auto_accept + end + + def on_delivery(event) + delivery = event.delivery + return unless delivery.link.receiver? + if delivery.readable? && !delivery.partial? + event.message = Qpid::Proton::Util::Engine.receive_message(delivery) + if event.link.local_closed? + if @auto_accept + delivery.update(Qpid::Proton::Disposition::RELEASED) + delivery.settle + end + else + begin + self.on_message(event) + if @auto_accept + delivery.update(Qpid::Proton::Disposition::ACCEPTED) + delivery.settle + end + rescue Qpid::Proton::Reject + delivery.update(Qpid::Proton::Disposition::REJECTED) + delivery.settle + rescue Qpid::Proton::Release + delivery.update(Qpid::Proton::Disposition::MODIFIED) + delivery.settle + end + end + elsif delivery.updated? && delivery.settled? + self.on_settled(event) + end + end + + def on_message(event) + Qpid::Proton::Event.dispatch(@delegate, :on_message, event) if !@delegate.nil? + end + + def on_settled(event) + Qpid::Proton::Event.dispatch(@delegate, :on_settled, event) if !@delegate.nil? + end + + end + +end http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e165313d/proton-c/bindings/ruby/lib/qpid_proton.rb ---------------------------------------------------------------------- diff --git a/proton-c/bindings/ruby/lib/qpid_proton.rb b/proton-c/bindings/ruby/lib/qpid_proton.rb index ef7f300..1fbf710 100644 --- a/proton-c/bindings/ruby/lib/qpid_proton.rb +++ b/proton-c/bindings/ruby/lib/qpid_proton.rb @@ -87,6 +87,7 @@ require "handler/c_adaptor" require "handler/wrapped_handler" require "handler/acking" require "handler/endpoint_state_handler" +require "handler/incoming_message_handler" require "handler/c_flow_controller" module Qpid::Proton --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
