yyyyyyyyyyy

> > mStompClient = Stomp.over(WebSocket.class, HostConfig.SERVICE_INCOMING); > > mStompClient.topic("/topic/hello").subscribe(topicMessage -> { > > Log.d("listenStomp", topicMessage.getPayload()); > > }); > > mStompClient.connect(); > > but Logcat show only following lines. >...

感谢！ 我先使用的队列是 /amq/queue/" + getTrimString(dataMap, "queueName")， 这种情况下，可以获得数据但是subscribe 中回调并没有进入。 我按您说的在前边加上 /queue/，会闪退，bug如下。 `io.reactivex.exceptions.OnErrorNotImplementedException: The exception was not handled due to missing onError handler in the subscribe() method call.` ` mStompClient.topic("/queue/amq/queue/" + getTrimString(dataMap,...