DeviseとActionCableの連携{エラー：An unauthorized connection attempt was rejected}

Question

前提・実現したいこと

プログラミング初心者で初投稿です。何卒よろしくお願いします。
Deviseを使い、User(ユーザー)モデルとConcierge(管理者)モデル間でActionCableを用いリアルタイムチャット機能を実装しています。

チャット入力フォームに文章を入力するも、反映されず、ターミナル上で下記エラーがでてしまいます。
Createアクション、Showアクションでチャットルーム自体は作成、ページに変遷は可能ですが、
チャット入力フォームに文章を入力するも、反映されず、ターミナル上で下記エラーがでてしまいます。

発生している問題・エラーメッセージ

Parameters: {"id"=>"14"}
  User Load (0.4ms)  SELECT `users`.* FROM `users` WHERE `users`.`id` = 2 ORDER BY `users`.`id` ASC LIMIT 1
  ChatRoom Load (1.1ms)  SELECT `chat_rooms`.* FROM `chat_rooms` WHERE `chat_rooms`.`id` = 14 LIMIT 1
  ↳ app/controllers/chat_rooms_controller.rb:15:in `show'
   (0.4ms)  SELECT `chat_room_users`.`concierge_id` FROM `chat_room_users` WHERE `chat_room_users`.`chat_room_id` = 14
  ↳ app/controllers/chat_rooms_controller.rb:16:in `show'
  Concierge Load (0.6ms)  SELECT `concierges`.* FROM `concierges` WHERE `concierges`.`id` = 4 LIMIT 1
  ↳ app/controllers/chat_rooms_controller.rb:17:in `show'
  Rendering chat_rooms/show.html.erb within layouts/application
  ChatMessage Load (3.2ms)  SELECT `chat_messages`.* FROM `chat_messages` WHERE `chat_messages`.`chat_room_id` = 14
  ↳ app/views/chat_rooms/show.html.erb:4
  Rendered collection of templates [0 times] (Duration: 0.0ms | Allocations: 3)
  Rendered chat_rooms/show.html.erb within layouts/application (Duration: 8.0ms | Allocations: 917)
[Webpacker] Everything's up-to-date. Nothing to do
Completed 200 OK in 126ms (Views: 103.4ms | ActiveRecord: 5.8ms | Allocations: 17564)


Started GET "/cable" for ::1 at 2021-06-06 16:27:20 +0900
Started GET "/cable/" [WebSocket] for ::1 at 2021-06-06 16:27:20 +0900
Successfully upgraded to WebSocket (REQUEST_METHOD: GET, HTTP_CONNECTION: Upgrade, HTTP_UPGRADE: websocket)
An unauthorized connection attempt was rejected
Finished "/cable/" [WebSocket] for ::1 at 2021-06-06 16:27:20 +0900

該当のソースコード

class ChatRoomsController < ApplicationController
  before_action :authenticate_user!

  def create
    current_user_chat_rooms = ChatRoomUser.where(user_id: current_user.id).map(&:chat_room)
    chat_room = ChatRoomUser.where(chat_room: current_user_chat_rooms, concierge_id: params[:concierge_id]).map(&:chat_room).first
    if chat_room.blank?
      chat_room = ChatRoom.create
      ChatRoomUser.create(chat_room: chat_room, user_id: current_user.id, concierge_id: params[:concierge_id])
    end
    redirect_to action: :show, id: chat_room.id
  end

  def show
    @chat_room = ChatRoom.find(params[:id])
    chat_room_user = @chat_room.chat_room_users.pluck(:concierge_id).first
    @chat_room_user = Concierge.find_by(id: chat_room_user)
    @chat_messages = ChatMessage.where(chat_room: @chat_room)
  end
  
end

<p>チャットルームページ</p>

<div id='chat-messages'>
  <%= render @chat_messages %>
</div>

<form>
  <textarea data-behavior="chat_room_speaker" data-chat_room_id="<%= @chat_room.id %>" placeholder="メッセージを入力" class="chat-room__message-form_textarea"></textarea>
</form>

module ApplicationCable
  class Connection < ActionCable::Connection::Base
    identified_by :current_user

    def connect
      reject_unauthorized_connection unless find_verified_user
    end

    private

      def find_verified_user
        self.current_user = env['warden'].user
      end
  end
end

class ChatRoomChannel < ApplicationCable::Channel
  def subscribed
    stream_from "chat_room_channel"
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
  end

  def speak(data)
    ChatMessage.create!(
      content: data['chat_message'],
      user_id: current_user.id,
      chat_room_id: data['chat_room_id']
    )
  end
end

import consumer from "./consumer"

const appChatRoom = consumer.subscriptions.create("ChatRoomChannel", {
  connected() {
    // Called when the subscription is ready for use on the server
  },

  disconnected() {
    // Called when the subscription has been terminated by the server
  },

  received(data) {
    const chatMessages = document.getElementById('chat-messages');
    chatMessages.insertAdjacentHTML('beforeend', data['chat_message']);
  },

  speak: function (chat_message, chat_room_id) {
    return this.perform('speak', { chat_message: chat_message, chat_room_id: chat_room_id });
  }
});
if (/chat_rooms/.test(location.pathname)) {
  $(document).on("keydown", ".chat-room__message-form_textarea", function (e) {
    if (e.key === "Enter") {
      const chat_room_id = $('textarea').data('chat_room_id')
      appChatRoom.speak(e.target.value, chat_room_id);
      e.target.value = '';
      e.preventDefault();
    }
  })
}

class ChatMessageBroadcastJob < ApplicationJob
  queue_as :default

  def perform(chat_message)
    ActionCable.server.broadcast 'chat_room_channel', chat_message: render_chat_message(chat_message)
  end

  private

    def render_chat_message(chat_message)
      ApplicationController.renderer.render(partial: 'chat_messages/chat_message', locals: { chat_message: chat_message, current_user: chat_message.user })
    end
end

試したこと

An unauthorized connection attempt was rejected

というエラーから、deviseのUser情報が正しくAction Cableに認証されていないと考えましたが、self.current_user = env['warden'].userで認証許可をしてます。

補足情報（FW/ツールのバージョンなど）

2日間かけ、自力で解決しようと試行錯誤しましたが無理でした。。
不足情報などありましたら修正しますので、ご教示いただければ幸いです。
よろしくお願いします。