class ActionCable::SubscriptionAdapter::PostgreSQL

def subscribe(channel, callback, success_callback = nil)
  listener.add_subscriber(channel_identifier(channel), callback, success_callback)
end