lib/runtime.rb in factor-0.5.08 vs lib/runtime.rb in factor-0.5.09

@@ -159,10 +159,16 @@
         ws.send(params.to_json)
       end
     end
 
     def error_handle_call(listener_response, &block)
-      block.call(OpenStruct.new(listener_response['payload'])) if block
+      payload = if listener_response['payload'].is_a?(Hash)
+        OpenStruct.new(listener_response['payload']) 
+      else
+        listener_response['payload']
+      end
+      block.call(payload) if block
+      
     rescue => ex
       error "Error in workflow definition: #{ex.message}"
       ex.backtrace.each do |line|
         error "  #{line}"
       end