Как подписаться на события хаба после того, как hubConnection был повторно подключен в signalR на Android?

Я использую signalR для приложения чата на android. Я хочу получать уведомления о событиях TeahcerAccepted, ChatReady, lessonChatReceived, которые поступают с сервера. Я создал hubProxy для hubConnection, добавил подписки, это работает очень хорошо (уведомляет обо всех событиях (все события)) перед повторным подключением, поэтому после повторного подключения (HubConnection – Очистка вызовов callbacks: Reconnecting) обратные вызовы не работают, хотя события происходят с сервера. Ниже кода класса обслуживания и журналов:

SignarRService.java

override fun onCreate() { super.onCreate() realm = Realm.getDefaultInstance() startSignalR() } private fun startSignalR() { Platform.loadPlatformComponent(AndroidPlatformComponent()) val neededToken = TOKEN.replace("bearer ","") val logger = Logger { message, level -> logd(level.toString() +": " + message,TAG_SIGNALR+"LogLevel") } mHubConnection = HubConnection("http://ututor.azurewebsites.net","authorization="+neededToken,true, logger) mHubProxy = mHubConnection!!.createHubProxy(SERVER_HUB_CHAT) mHubConnection!!.closed { logd("closed",TAG_SIGNALR) connectSignalR() } connectSignalR() } fun connectSignalR(){ mHubProxy!!.subscribe(object : Any() { @SuppressWarnings("unused") fun TeacherAccepted(message: String){ logd(message,TAG_SIGNALR) notifyTeacherAccepted(message) } @SuppressWarnings("unused") fun ChatReady(){ notifyChatReady() } @SuppressWarnings("unused") fun lessonChatReceived(message: CustomMessage){ logd(Gson().toJson(message, CustomMessage::class.java)) } }) val awaitConnection = mHubConnection!!.start(LongPollingTransport(mHubConnection!!.logger)) try { awaitConnection.get() } catch (e: InterruptedException) { Log.e("onErrorOccured",e.toString()) } catch (e: ExecutionException) { Log.e("onErrorOccured",e.toString()) } mHubConnection!!.received( { json -> Log.e("onMessageReceived ", json.toString()) }) } 

Журналы я получаю только важные точки из журналов не все журналы

  Information: HubConnection - Creating hub proxy: chat Information: HubProxy chat - Subscribe to event ChatReady Information: HubProxy chat - Creating new subscription for: chatready Information: HubProxy chat - Subscribe to event TeacherAccepted Information: HubProxy chat - Creating new subscription for: teacheraccepted Information: HubProxy chat - Subscribe to event lessonChatReceived Information: HubProxy chat - Creating new subscription for: lessonchatreceived Verbose: HubConnection - Entered startLock in start //Here must be connection process Verbose: Request executed Verbose: longPolling - Trigger onData with data: {"C":"d-300E3EC2-Hr,0|LH,0|Kd,5|LI,2|Kf,0","M":[{"H":"chat","M":"TeacherAccepted","A":[101]}]} Verbose: HubConnection - Received data: Verbose: MessageId received: d-300E3EC2-Hr,0|LH,0|Kd,5|LI,2|Kf,0 Verbose: Invoking OnReceived with: null Verbose: HubConnection - Invoking messageReceived with: {"H":"chat","M":"TeacherAccepted","A":[101]}d: {"H":"chat","M":"TeacherAccepted","A":[101]} Information: HubConnection - Processing message Verbose: HubConnection - Getting HubInvocation from message Verbose: HubConnection - Message for: chat Verbose: HubConnection - Invoking event: teacheraccepted with arguments [101] Verbose: HubProxy chat - Handling dynamic subscription: TeacherAccepted Verbose: HubProxy chat - Invoking method for dynamic subscription: TeacherAccepted //Callback was called //Here must be unneccecary code // Starts reconnecting Information: HubConnection - Slow connection detected Information: HubConnection - Timeout Verbose: HubConnection - Stopping Heartbeat monitor Information: HubConnection - Restarting the transport Verbose: HubConnection - Entered startLock in startTransport Information: HubConnection - Starting the transport Verbose: HubConnection - Stopping heartbeat monitor Verbose: HubConnection - Clearing invocation callbacks: Reconnecting //Here clears Verbose: HubConnection - Starting transport for Reconnection Verbose: longPolling - Trigger onData with data: {"C":"d-300E3EC2-Hr,0|LH,0|Kd,6|LI,2|Kf,0","M":[{"H":"chat","M":"ChatReady","A":[]}]} Verbose: HubConnection - Received data: Verbose: MessageId received: d-300E3EC2-Hr,0|LH,0|Kd,6|LI,2|Kf,0 Verbose: Invoking OnReceived with: null //Callbacks does not work 

Как переадресовать события или сделать что-то еще для этой проблемы? Пожалуйста, помогите, я не могу решить за 3 дня эту проблему.

Intereting Posts
Изображение не отображается в Activity (это нормально в AppCompatActivity) Как вызвать метод Котлин с более чем одной подобной сигнатурой с лямбдой? Невыполнение результата по результату Разрешены только безопасные или неаудированные звонки, разрешенные для нулевого типа приемника arraylist MapView в режиме Lite сбой при вызове onSaveInstanceState Как я могу получить перечисление Kotlin одинакового поведения как cpp Добавление «предоставленной» конфигурации в библиотеку kotlin / java с использованием gradle Почему я не могу получить значения моего файла JSON? сигнал 7 (SIGBUS), код 2 (BUS_ADRERR) Как правильно переопределить метод, возвращающий экземпляр родового класса в Котлин Что такое эквивалент Kotlin строки Java ? Kotlin – Использование Realm Module в android Могу ли я создать KType из reified T Дженерики и абстрактный класс в Котлине Kotlin – Как сделать делегат недвижимости по карте с пользовательским именем?