Angular 2 stomp服务消费

Question

我得到了未定义的responseBody，但我得到了msg_body中的subscribe响应。responseBody有什么问题？

 let stomp_subscription = this._stompService.subscribe('/topic/queue');
stomp_subscription.map((message: Message) => {
  return message.body;
}).subscribe((msg_body: string) => {
  console.log(`Received: ${msg_body}`);
  this.responseBody = JSON.parse(msg_body);
  console.log('RESPONSECODE' + this.responseBody.ResponseInfo.ResponseCode);
});

Answer 1

您正在使用来自Observable的.map()运算符的return语句。因此，该值不会传递给对可观察对象的下一次.subscribe()调用。你能试试下面的代码吗？

    let stomp_subscription = this._stompService.subscribe('/topic/queue');
    stomp_subscription.map((message: Message) => message.body )
     .subscribe((msg_body: string) => {
      console.log(`Received: ${msg_body}`);
      this.responseBody = JSON.parse(msg_body);
      console.log('RESPONSECODE' + this.responseBody.ResponseInfo.ResponseCode);
    });