diff --git a/src/main/ruby/lib/merritt_zk_queue_item.rb b/src/main/ruby/lib/merritt_zk_queue_item.rb index 786ce9b..e36667d 100644 --- a/src/main/ruby/lib/merritt_zk_queue_item.rb +++ b/src/main/ruby/lib/merritt_zk_queue_item.rb @@ -186,10 +186,8 @@ def payload_text end def payload_object - json = {payload: payload_text} - if json? - json = JSON.parse(payload_text, symbolize_names: true) - end + json = { payload: payload_text } + json = JSON.parse(payload_text, symbolize_names: true) if json? json[:queueNode] = '/jobs' json[:id] = @id json[:date] = time.to_s