class TDL::JSONRPCSerializationProvider

Public Class Methods

new() click to toggle source
# File lib/tdl/queue/serialization/json_rpc_serialization_provider.rb, line 7
def initialize
  @logger = Logging.logger[self]
end

Public Instance Methods

deserialize(msg) click to toggle source
# File lib/tdl/queue/serialization/json_rpc_serialization_provider.rb, line 11
def deserialize(msg)
  begin
    request_data = JSON.parse(msg.body.gsub("\n", '\n'))
    Request.new(msg, request_data)
  rescue Exception => e
    raise DeserializationException,'Invalid message format: '+msg.body, e.backtrace
  end
end
serialize(response) click to toggle source
# File lib/tdl/queue/serialization/json_rpc_serialization_provider.rb, line 20
def serialize(response)
  if response
    hash = response.to_h
    JSON.unparse(hash)
  end
end