Change ACK strategy to client-individual

julianghionoiu · Jul 31, 2016 · 5e37dcd · 5e37dcd
1 parent 8f5d277
commit 5e37dcd
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 7 deletions.
diff --git a/lib/tdl/abstractions/response/valid_response.rb b/lib/tdl/abstractions/response/valid_response.rb
@@ -2,7 +2,7 @@
 
 module TDL
   class ValidResponse
-    attr_reader :result, :id, :client_action
+    attr_reader :id, :result, :client_action
 
     def initialize(id, result, client_action)
       @id = id

diff --git a/lib/tdl/client.rb b/lib/tdl/client.rb
@@ -6,6 +6,7 @@
 require 'tdl/actions/stop_action'
 
 require 'tdl/serialization/json_rpc_serialization_provider'
+
 module TDL
 
   class Client

diff --git a/lib/tdl/transport/remote_broker.rb b/lib/tdl/transport/remote_broker.rb
@@ -7,7 +7,7 @@ def initialize(hostname, port, unique_id)
     end
 
     def subscribe(handling_strategy)
-      @stomp_client.subscribe("/queue/#{@unique_id}.req", {:ack => 'client', 'activemq.prefetchSize' => 1}) do |msg|
+      @stomp_client.subscribe("/queue/#{@unique_id}.req", {:ack => 'client-individual', 'activemq.prefetchSize' => 1}) do |msg|
         request = @serialization_provider.deserialize(msg)
         handling_strategy.process_next_request_from(self, request)
       end

diff --git a/tdl-client-ruby.iml b/tdl-client-ruby.iml
@@ -2,11 +2,7 @@
 <module type="RUBY_MODULE" version="4">
   <component name="FacetManager">
     <facet type="gem" name="Ruby Gem">
-      <configuration>
-        <option name="GEM_APP_ROOT_PATH" value="$MODULE_DIR$" />
-        <option name="GEM_APP_TEST_PATH" value="$MODULE_DIR$/test" />
-        <option name="GEM_APP_LIB_PATH" value="$MODULE_DIR$/lib" />
-      </configuration>
+      <configuration />
     </facet>
   </component>
   <component name="NewModuleRootManager" inherit-compiler-output="true">
@@ -15,6 +11,7 @@
       <sourceFolder url="file://$MODULE_DIR$/test" isTestSource="true" />
       <sourceFolder url="file://$MODULE_DIR$/lib" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/features" isTestSource="true" />
+      <excludeFolder url="file://$MODULE_DIR$/broker" />
       <excludeFolder url="file://$MODULE_DIR$/broker/.cache" />
       <excludeFolder url="file://$MODULE_DIR$/coverage" />
     </content>
@@ -53,4 +50,8 @@
     <orderEntry type="library" scope="PROVIDED" name="unf (v0.1.4, rbenv: 2.2.2) [gem]" level="application" />
     <orderEntry type="library" scope="PROVIDED" name="unf_ext (v0.0.7.1, rbenv: 2.2.2) [gem]" level="application" />
   </component>
+  <component name="RModuleSettingsStorage">
+    <LOAD_PATH number="1" string0="$MODULE_DIR$/../../tdl-warmup/ruby/lib" />
+    <I18N_FOLDERS number="0" />
+  </component>
 </module>