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