{"action":"closed","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-netflix/issues/2949","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-netflix","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-netflix/issues/2949/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-netflix/issues/2949/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-netflix/issues/2949/events","html_url":"https://github.com/spring-cloud/spring-cloud-netflix/issues/2949","id":325028621,"number":2949,"title":"Turbine Stream JsonParseException: Unexpected character (',' (code 44)): Expected space separating root-level values","user":{"login":"sureshsivan","id":4368713,"avatar_url":"https://avatars2.githubusercontent.com/u/4368713?v=4","gravatar_id":"","url":"https://api.github.com/users/sureshsivan","html_url":"https://github.com/sureshsivan","followers_url":"https://api.github.com/users/sureshsivan/followers","following_url":"https://api.github.com/users/sureshsivan/following{/other_user}","gists_url":"https://api.github.com/users/sureshsivan/gists{/gist_id}","starred_url":"https://api.github.com/users/sureshsivan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sureshsivan/subscriptions","organizations_url":"https://api.github.com/users/sureshsivan/orgs","repos_url":"https://api.github.com/users/sureshsivan/repos","events_url":"https://api.github.com/users/sureshsivan/events{/privacy}","received_events_url":"https://api.github.com/users/sureshsivan/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":2,"created_at":"2018-05-21T19:17:36Z","updated_at":"2018-05-21T19:39:02Z","closed_at":"2018-05-21T19:39:02Z","author_association":"NONE","body":"When using Turbine Stream Server to aggregate hystrix data, it fails while parsing the hystrix message payload. This issue was closed already with older versions of spring cloud. but its happening again with spring cloud version ```Finchley.RC1```\r\n\r\n**Env**\r\n```Spring Cloud Finchley.RC1```\r\n```java version \"1.8.0_144\"```\r\n```rabbit version 3.7.2```\r\n\r\n**Minimal Reproduction**\r\n\r\nrun rabbit as docker container\r\n```\r\n$ docker run -d --hostname my-rabbit -p 5672:5672 -p 15672:15672 --name some-rabbit rabbitmq:3-management\r\n```\r\n\r\nspring boot web app\r\n[web.zip](https://github.com/spring-cloud/spring-cloud-netflix/files/2023780/web.zip)\r\n\r\nspring boot turbine app\r\n[turbine.zip](https://github.com/spring-cloud/spring-cloud-netflix/files/2023779/turbine.zip)\r\n\r\nTurbine configured to run on port 8090\r\nweb app configured to run on port 8080\r\n\r\nInvoke endpoint\r\n```bash\r\ncurl http://localhost:8080/ping\r\n```\r\n\r\n**Exception Log**\r\n```com.fasterxml.jackson.core.JsonParseException: Unexpected character (',' (code 44)): Expected space separating root-level values\r\n at [Source: (String)\"123,34,111,114,105,103,105,110,34,58,123,34,104,111,115,116,34,58,34,49,48,46,50,51,46,57,50,46,51,53,34,44,34,112,111,114,116,34,58,56,48,56,48,44,34,115,101,114,118,105,99,101,73,100,34,58,34,119,101,98,34,44,34,105,100,34,58,34,97,112,112,108,105,99,97,116,105,111,110,45,49,34,125,44,34,100,97,116,97,34,58,123,34,116,121,112,101,34,58,34,72,121,115,116,114,105,120,84,104,114,101,97,100,80,111,111,108,34,44,34,110,97,109,101,34,58,34,84,101,115,116,67,111,110,116,114,111,108,108,101,114,34,44,\"[truncated 1525 chars]; line: 1, column: 5]\r\n\tat com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1798) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:663) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.base.ParserMinimalBase._reportUnexpectedChar(ParserMinimalBase.java:561) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.base.ParserMinimalBase._reportMissingRootWS(ParserMinimalBase.java:608) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.json.ReaderBasedJsonParser._verifyRootSpace(ReaderBasedJsonParser.java:1654) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.json.ReaderBasedJsonParser._parsePosNumber(ReaderBasedJsonParser.java:1297) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.core.json.ReaderBasedJsonParser.nextToken(ReaderBasedJsonParser.java:744) ~[jackson-core-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:4129) ~[jackson-databind-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3988) ~[jackson-databind-2.9.3.jar:2.9.3]\r\n\tat com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2992) ~[jackson-databind-2.9.3.jar:2.9.3]\r\n\tat org.springframework.cloud.netflix.turbine.stream.HystrixStreamAggregator.sendToSubject(HystrixStreamAggregator.java:73) ~[spring-cloud-netflix-turbine-stream-2.0.0.RC1.jar:2.0.0.RC1]\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_144]\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_144]\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_144]\r\n\tat java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_144]\r\n\tat org.springframework.expression.spel.support.ReflectiveMethodExecutor.execute(ReflectiveMethodExecutor.java:120) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.ast.MethodReference.getValueInternal(MethodReference.java:111) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.ast.MethodReference.access$000(MethodReference.java:54) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.ast.MethodReference$MethodValueRef.getValue(MethodReference.java:391) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.ast.CompoundExpression.getValueInternal(CompoundExpression.java:89) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.ast.SpelNodeImpl.getTypedValue(SpelNodeImpl.java:116) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:371) [spring-expression-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.integration.util.AbstractExpressionEvaluator.evaluateExpression(AbstractExpressionEvaluator.java:169) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.util.AbstractExpressionEvaluator.evaluateExpression(AbstractExpressionEvaluator.java:157) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.util.MessagingMethodInvokerHelper.invokeExpression(MessagingMethodInvokerHelper.java:614) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.util.MessagingMethodInvokerHelper.invokeHandlerMethod(MessagingMethodInvokerHelper.java:605) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.util.MessagingMethodInvokerHelper.processInternal(MessagingMethodInvokerHelper.java:468) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.util.MessagingMethodInvokerHelper.process(MessagingMethodInvokerHelper.java:312) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:104) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.handler.ServiceActivatingHandler.handleRequestMessage(ServiceActivatingHandler.java:93) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:109) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:158) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:132) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:105) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:73) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:445) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:394) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:181) [spring-messaging-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:160) [spring-messaging-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) [spring-messaging-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:108) [spring-messaging-5.0.6.RELEASE.jar:5.0.6.RELEASE]\r\n\tat org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:203) [spring-integration-core-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$1100(AmqpInboundChannelAdapter.java:59) [spring-integration-amqp-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.lambda$onMessage$0(AmqpInboundChannelAdapter.java:217) [spring-integration-amqp-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287) ~[spring-retry-1.2.2.RELEASE.jar:na]\r\n\tat org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:180) ~[spring-retry-1.2.2.RELEASE.jar:na]\r\n\tat org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.onMessage(AmqpInboundChannelAdapter.java:214) [spring-integration-amqp-5.0.5.RELEASE.jar:5.0.5.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1414) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1337) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1324) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1303) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:785) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:769) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$700(SimpleMessageListenerContainer.java:77) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1010) ~[spring-rabbit-2.0.3.RELEASE.jar:2.0.3.RELEASE]\r\n\tat java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_144]\r\n```\r\n\r\n**Previously Closed Issues :** \r\n[https://github.com/spring-cloud-samples/turbine/issues/1](https://github.com/spring-cloud-samples/turbine/issues/1)\r\n[https://github.com/spring-cloud/spring-cloud-netflix/issues/126](https://github.com/spring-cloud/spring-cloud-netflix/issues/126)"}}
{"actor":{"display_login":"sureshsivan"}}