aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/channel/base.rb
diff options
context:
space:
mode:
authorPratik Naik <pratiknaik@gmail.com>2015-10-19 15:14:22 -0500
committerPratik Naik <pratiknaik@gmail.com>2015-10-19 15:14:22 -0500
commit506d84c157b041208f40b7034cac9c5d5e66fff5 (patch)
treefba84aec142722d5381906a2ed5d9c01dc5e2152 /lib/action_cable/channel/base.rb
parent0d99cfd5ca755643a23beec22513072987c8edba (diff)
downloadrails-506d84c157b041208f40b7034cac9c5d5e66fff5.tar.gz
rails-506d84c157b041208f40b7034cac9c5d5e66fff5.tar.bz2
rails-506d84c157b041208f40b7034cac9c5d5e66fff5.zip
Make sure the subscription confirmaion is only sent out once
Diffstat (limited to 'lib/action_cable/channel/base.rb')
-rw-r--r--lib/action_cable/channel/base.rb12
1 files changed, 10 insertions, 2 deletions
diff --git a/lib/action_cable/channel/base.rb b/lib/action_cable/channel/base.rb
index 0b9aa2f4ad..221730dbc4 100644
--- a/lib/action_cable/channel/base.rb
+++ b/lib/action_cable/channel/base.rb
@@ -180,6 +180,10 @@ module ActionCable
@defer_subscription_confirmation
end
+ def subscription_confirmation_sent?
+ @subscription_confirmation_sent
+ end
+
private
def delegate_connection_identifiers
connection.identifiers.each do |identifier|
@@ -231,8 +235,12 @@ module ActionCable
end
def transmit_subscription_confirmation
- logger.info "#{self.class.name} is transmitting the subscription confirmation"
- connection.transmit ActiveSupport::JSON.encode(identifier: @identifier, type: SUBSCRIPTION_CONFIRMATION_INTERNAL_MESSAGE)
+ unless subscription_confirmation_sent?
+ logger.info "#{self.class.name} is transmitting the subscription confirmation"
+ connection.transmit ActiveSupport::JSON.encode(identifier: @identifier, type: SUBSCRIPTION_CONFIRMATION_INTERNAL_MESSAGE)
+
+ @subscription_confirmation_sent = true
+ end
end
end