class EventQ::SerializationProviders::JRuby::OjSerializationProvider

Public Class Methods

new() click to toggle source
# File lib/eventq_base/serialization_providers/jruby/oj_serialization_provider.rb, line 5
def initialize
  @json_serializer = EventQ::SerializationProviders::JsonSerializationProvider.new
  @oj_serializer = Oj::Serializer.new
end

Public Instance Methods

deserialize(json) click to toggle source
# File lib/eventq_base/serialization_providers/jruby/oj_serialization_provider.rb, line 14
def deserialize(json)
  begin
    return @oj_serializer.load(json)
  rescue
    EventQ.log(:debug, "[#{self.class}] - Failed to deserialize using Oj, falling back to JsonSerializationProvider.")
    return @json_serializer.deserialize(json)
  end
end
serialize(object) click to toggle source
# File lib/eventq_base/serialization_providers/jruby/oj_serialization_provider.rb, line 10
def serialize(object)
  @oj_serializer.dump(object)
end