From 5ea0a3055dd38e781f172e5247ab3c136cae876d Mon Sep 17 00:00:00 2001 From: Howard Gao Date: Mon, 16 Mar 2015 22:39:00 +0800 Subject: [PATCH] Fix proton-cpp pom missing version Fix proton-ruby script (update according to proton 0.8) Fix core example doc --- examples/core/embedded-remote/readme.html | 2 +- examples/core/embedded/readme.html | 2 +- examples/jms/proton-cpp/pom.xml | 1 + examples/jms/proton-ruby/src/main/scripts/receive.rb | 9 +++++---- examples/jms/proton-ruby/src/main/scripts/send.rb | 4 ++-- 5 files changed, 10 insertions(+), 8 deletions(-) mode change 100644 => 100755 examples/jms/proton-ruby/src/main/scripts/receive.rb mode change 100644 => 100755 examples/jms/proton-ruby/src/main/scripts/send.rb diff --git a/examples/core/embedded-remote/readme.html b/examples/core/embedded-remote/readme.html index 9e8d338080..a5cc882460 100644 --- a/examples/core/embedded-remote/readme.html +++ b/examples/core/embedded-remote/readme.html @@ -33,7 +33,7 @@ under the License.

Example step-by-step

-

To run the example, simply type mvn -Pserver from this directory to start the server and mvn -Pclient to run the client example

+

To run the example, simply type mvn verify -Pserver from this directory to start the server and mvn verify -Pclient to run the client example

In this we don't use any configuration files. (Everything is embedded). We simply instantiate ConfigurationImpl, ActiveMQServer, start it and operate on JMS regularly


    diff --git a/examples/core/embedded/readme.html b/examples/core/embedded/readme.html index dcec9b69b2..441a68be15 100644 --- a/examples/core/embedded/readme.html +++ b/examples/core/embedded/readme.html @@ -38,7 +38,7 @@ under the License.

    ActiveMQ Embedded could be used from very simple use cases with only InVM support to very complex cases with clustering, persistence and fail over.

    Example step-by-step

    -

    To run the example, simply type mvn -Pexample from this directory

    +

    To run the example, simply type mvn verify -Pexample from this directory

    In this we don't use any configuration files. (Everything is embedded). We simply instantiate ConfigurationImpl, ActiveMQServer, start it and operate on JMS regularly

      diff --git a/examples/jms/proton-cpp/pom.xml b/examples/jms/proton-cpp/pom.xml index 6b3defe7fd..a7888b4774 100644 --- a/examples/jms/proton-cpp/pom.xml +++ b/examples/jms/proton-cpp/pom.xml @@ -50,6 +50,7 @@ under the License. org.apache.geronimo.specs geronimo-jms_2.0_spec + ${geronimo.jms.2.spec.version} org.apache.activemq diff --git a/examples/jms/proton-ruby/src/main/scripts/receive.rb b/examples/jms/proton-ruby/src/main/scripts/receive.rb old mode 100644 new mode 100755 index 4019bd2f95..93228ff4b8 --- a/examples/jms/proton-ruby/src/main/scripts/receive.rb +++ b/examples/jms/proton-ruby/src/main/scripts/receive.rb @@ -20,6 +20,7 @@ require 'qpid_proton' messenger = Qpid::Proton::Messenger.new() messenger.incoming_window = 10 +messenger.timeout = 10000 begin messenger.start @@ -39,7 +40,7 @@ end msg = Qpid::Proton::Message.new begin - messenger.receive(10) + messenger.receive(1) rescue Qpid::Proton::ProtonError => error puts "ERROR: #{error.message}" exit @@ -49,14 +50,14 @@ msg = Qpid::Proton::Message.new begin messenger.get(msg) # for 0.5: - messenger.accept() + # messenger.accept() # for 0.4: #messenger.accept(messenger.incoming_tracker, 0)#1 would mean cumulative # optional and the same in both versions (messenger will # settle itself when tracker passes out the window) - messenger.settle(messenger.incoming_tracker, 0) + # messenger.settle(messenger.incoming_tracker) rescue Qpid::Proton::Error => error @@ -66,7 +67,7 @@ msg = Qpid::Proton::Message.new puts "Address: #{msg.address}" puts "Subject: #{msg.subject}" - puts "Content: #{msg.content}" + puts "Content: #{msg.body}" puts "Message ID: #{msg.id}" end diff --git a/examples/jms/proton-ruby/src/main/scripts/send.rb b/examples/jms/proton-ruby/src/main/scripts/send.rb old mode 100644 new mode 100755 index ab4a2a4457..1287280c71 --- a/examples/jms/proton-ruby/src/main/scripts/send.rb +++ b/examples/jms/proton-ruby/src/main/scripts/send.rb @@ -26,7 +26,7 @@ messenger.start msg = Qpid::Proton::Message.new msg.address = address msg.subject = "The time is #{Time.new}" -msg.content = "Hello world!" +msg.body = "Hello world!" msg.correlation_id = "554545" begin @@ -44,6 +44,6 @@ rescue Qpid::Proton::ProtonError => error exit end -puts "SENT: " + msg.content +puts "SENT: " + msg.body messenger.stop