lib/ably/realtime/client/incoming_message_dispatcher.rb in ably-0.8.14 vs lib/ably/realtime/client/incoming_message_dispatcher.rb in ably-0.8.15
- old
+ new
@@ -176,17 +176,17 @@
end
end
def ack_messages(messages)
messages.each do |message|
- logger.debug "Calling ACK success callbacks for #{message.class.name} - #{message.to_json}"
+ logger.debug "Calling ACK success callbacks for #{message.class.name} - #{message.to_safe_json}"
message.succeed message
end
end
def nack_messages(messages, protocol_message)
messages.each do |message|
- logger.debug "Calling NACK failure callbacks for #{message.class.name} - #{message.to_json}, protocol message: #{protocol_message}"
+ logger.debug "Calling NACK failure callbacks for #{message.class.name} - #{message.to_safe_json}, protocol message: #{protocol_message}"
message.fail protocol_message.error
end
end
def drop_pending_queue_from_ack(ack_protocol_message)