Merge pull request #11 from julianghionoiu/cleanup

Remove old client code
julianghionoiu · Feb 7, 2018 · a1933b3 · a1933b3
2 parents 0e13f51 + 062309d
commit a1933b3
Show file tree

Hide file tree

Showing 5 changed files with 29 additions and 145 deletions.
diff --git a/examples/add_numbers.rb b/examples/add_numbers.rb
diff --git a/lib/tdl.rb b/lib/tdl.rb
@@ -1,4 +1,3 @@
-require 'tdl/queue/client'
 require 'tdl/queue/implementation_runner_config'
 require 'tdl/queue/queue_based_implementation_runner'
 require 'tdl/queue/queue_based_implementation_runner_builder'

diff --git a/lib/tdl/queue/client.rb b/lib/tdl/queue/client.rb
diff --git a/lib/tdl/queue/queue_based_implementation_runner.rb b/lib/tdl/queue/queue_based_implementation_runner.rb
@@ -1,6 +1,6 @@
 require 'logging'
-
 require 'tdl/queue/processing_rules'
+require 'tdl/queue/transport/remote_broker'
 
 module TDL
     class QueueBasedImplementationRunner
@@ -73,3 +73,29 @@ def process_next_request_from(remote_broker, request)
         end
     end
 end
+
+class AuditStream
+
+    def initialize
+      @logger = Logging.logger[self]
+      start_line
+    end
+
+    def start_line
+      @str = ''
+    end
+
+    def log(auditable)
+      text = auditable.audit_text
+      if not text.empty? and @str.length > 0
+        @str << ', '
+      end
+
+      @str << text
+    end
+
+    def end_line
+      @logger.info @str
+    end
+
+end
diff --git a/lib/tdl/queue/transport/remote_broker.rb b/lib/tdl/queue/transport/remote_broker.rb
@@ -1,4 +1,6 @@
+require 'stomp'
 require 'tdl/thread_timer'
+require 'tdl/queue/serialization/json_rpc_serialization_provider'
 
 module TDL
   class RemoteBroker