lib/submodules/ably-ruby/lib/ably/rest/channel.rb in ably-rest-0.9.1 vs lib/submodules/ably-ruby/lib/ably/rest/channel.rb in ably-rest-0.9.2
- old
+ new
@@ -63,11 +63,11 @@
[{ name: name, data: data }.merge(attributes)]
end
payload = messages.map do |message|
Ably::Models::Message(message.dup).tap do |msg|
- msg.encode self
+ msg.encode client.encoders, options
next if msg.client_id.nil?
if msg.client_id == '*'
raise Ably::Exceptions::IncompatibleClientId.new('Wildcard client_id is reserved and cannot be used when publishing messages', 400, 40012)
end
@@ -132,10 +132,10 @@
def base_path
"/channels/#{Addressable::URI.encode(name)}"
end
def decode_message(message)
- message.decode self
+ message.decode client.encoders, options
rescue Ably::Exceptions::CipherError, Ably::Exceptions::EncoderError => e
client.logger.error "Decoding Error on channel '#{name}', message event name '#{message.name}'. #{e.class.name}: #{e.message}"
end
end
end