在 Spring-XD analytic-pmml 流上，通过 mqtt 代理错误发布 json 数据？
On Spring-XD analytic-pmml stream, publishing json data via mqtt broker error?
这是我的流定义-
xd:>stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy
创建并部署了新流'test'
当我尝试发布 JSON 数据时
{
"sepalLength": "6.4",
"sepalWidth": "3.2",
"petalLength": "4.5",
"petalWidth": "1.5"
}
通过代理获取错误。完整错误如下：-
2017-03-11T12:24:30+0530 1.3.1.RELEASE ERROR MQTT Call: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Unhandled exception for GenericMessage [payload={
"sepalLength": "6.4",
"sepalWidth": "3.2",
"petalLength": "4.5",
"petalWidth": "1.5"
}, headers={mqtt_retained=false, mqtt_qos=0, id=fa97c439-5896-dc53-6c4a-7a8af57b73de, mqtt_topic=irisPayload, mqtt_duplicate=false, timestamp=1489215270746}]
org.springframework.integration.transformer.MessageTransformationException: Failed to transform Message; nested exception is org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:95) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:99) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:231) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:154) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:102) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:231) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:154) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:102) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter.messageArrived(MqttPahoMessageDrivenChannelAdapter.java:314) ~[spring-integration-mqtt-4.2.5.RELEASE.jar!/:na]
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:354) [org.eclipse.paho.client.mqttv3-1.0.2.jar!/:na]
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:162) [org.eclipse.paho.client.mqttv3-1.0.2.jar!/:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101]
Caused by: org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:96) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.transformer.AbstractMessageProcessingTransformer.transform(AbstractMessageProcessingTransformer.java:90) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:89) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
... 44 common frames omitted
Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.xd.analytics.ml.pmml.TuplePmmlAnalyticInputDataMapper.mapInput(TuplePmmlAnalyticInputDataMapper.java:37) ~[na:na]
at org.springframework.xd.analytics.ml.MappedAnalytic.evaluate(MappedAnalytic.java:64) ~[na:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_101]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_101]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_101]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_101]
at org.springframework.expression.spel.support.ReflectiveMethodExecutor.execute(ReflectiveMethodExecutor.java:113) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference.getValueInternal(MethodReference.java:102) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference.access[=14=]0(MethodReference.java:49) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference$MethodValueRef.getValue(MethodReference.java:347) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.CompoundExpression.getValueInternal(CompoundExpression.java:88) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.SpelNodeImpl.getTypedValue(SpelNodeImpl.java:131) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:330) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.util.AbstractExpressionEvaluator.evaluateExpression(AbstractExpressionEvaluator.java:166) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.util.MessagingMethodInvokerHelper.processInternal(MessagingMethodInvokerHelper.java:317) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.util.MessagingMethodInvokerHelper.process(MessagingMethodInvokerHelper.java:155) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:93) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
... 46 common frames omitted
2017-03-11T12:24:30+0530 1.3.1.RELEASE ERROR MQTT Call: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:MqttException; retrying...
非常感谢。这是更新错误日志消息，推荐后：
2017-03-12T00:21:11+0530 1.3.1.RELEASE ERROR MQTT Ping: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:Timed out waiting for a response from the server; retrying...
2017-03-12T00:25:02+0530 1.3.1.RELEASE ERROR MQTT Rec: xd.mqtt.client.id.src server.NIOServerCnxnFactory - Thread Thread[MQTT Rec: xd.mqtt.client.id.src,5,main] died
java.lang.NoClassDefFoundError: org/eclipse/paho/client/mqttv3/internal/wire/MqttReceivedMessage
at org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage.createWireMessage(MqttWireMessage.java:189) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage.createWireMessage(M qttWireMessage.java:163) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage (MqttInputStream.java:83) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:107 ) ~[na:na]
at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_101]
Caused by: java.lang.ClassNotFoundException: org.eclipse.paho.client.mqttv3.internal.wire.MqttReceivedMessage
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~ [na:1.8.0_101]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_101]
at org.springframework.xd.module.support.ParentLastURLClassLoader.loadClass(ParentL astURLClassLoader.java:87) ~[spring-xd-module- 1.3.1.RELEASE.jar:1.3.1.RELEASE]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_101]
... 5 common frames omitted
2017-03-12T00:26:11+0530 1.3.1.RELEASE ERROR MQTT Ping: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:Timed out waiting for a response from the server; retrying...
pmml 模块需要 Tuple - 尝试将 --outputType=application/x-xd-tuple 添加到 mqtt 源定义
xd:>stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload' --outputType=application/x-xd-tuple | analytic-pmml ...
编辑
我用 TCP 源测试了它...
xd:>stream create --name pmml1 --definition "tcp --outputType=application/x-xd-tuple | analytic-pmml --modelName=iris-flower-classification-naive-bayes-1 --location=/Users/grussell/Downloads/spring-xd-modules-master/analytics-ml-pmml/src/test/resources/analytics/pmml/iris-flower-classification-naive-bayes-1.pmml.xml --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width' --outputFieldMapping='Predicted_Species:predictedSpecies' | log" --deploy
并使用telnet localhost 1234发送：
{ "sepalLength": 6.4, "sepalWidth": 3.2, "petalLength":4.5, "petalWidth":1.5 }
而且效果很好。
EDIT2
我刚用 MQTT 测试过，没问题...
2017-03-11T11:25:58-0500 1.3.1.RELEASE INFO xdbus.pmml1.1-1 sink.pmml1 -
{"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}
流：
xd:>stream create --name pmml1 --definition "mqtt --topics=pmml --outputType=application/x-xd-tuple | analytic-pmml --modelName=iris-flower-classification-naive-bayes-1 --location=/Users/grussell/Downloads/spring-xd-modules-master/analytics-ml-pmml/src/test/resources/analytics/pmml/iris-flower-classification-naive-bayes-1.pmml.xml --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width' --outputFieldMapping='Predicted_Species:predictedSpecies' | log" --deploy
EDIT3
这是我测试的 DEBUG 日志（针对 logback.groovy 中的类别 org.springframework.integration）；我建议你把你的和这个比较一下，看看哪里出了问题...
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src channel.DirectChannel - preSend on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=a4f09671-c617-bfce-c2f7-e1844a8772ff, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888127}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [41, org.springframework.xd.tuple.DefaultTuple] with serializer org.springframework.xd.tuple.serializer.kryo.DefaultTupleSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [42, java.util.ArrayList] with serializer com.esotericsoftware.kryo.serializers.CollectionSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src outbound.AmqpOutboundEndpoint - org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@2cc14cf received message: GenericMessage [payload=byte[89], headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=58499b9d-6a38-ea36-ac8e-93c704d61a1b, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888135}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src outbound.AmqpOutboundEndpoint - handler 'org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@2cc14cf' produced no reply for request Message: GenericMessage [payload=byte[89], headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=58499b9d-6a38-ea36-ac8e-93c704d61a1b, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888135}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src channel.DirectChannel - postSend (sent=true) on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=a4f09671-c617-bfce-c2f7-e1844a8772ff, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888127}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'pmml1.0.bridge', message: GenericMessage [payload=byte[89], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=b325de8d-e28b-0c6c-e3e2-54e8ab22c66d, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888152}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 transformer.MessageTransformingHandler - org.springframework.integration.config.TransformerFactoryBean#0 received message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=e4e5e571-581c-24e2-6d08-73bd1340d483, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 outbound.AmqpOutboundEndpoint - org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6c6a8365 received message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=7ffad6d0-db78-8ffd-cc9d-7619e9359834, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_consumerQueue] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_consumerTag] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 outbound.AmqpOutboundEndpoint - handler 'org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6c6a8365' produced no reply for request Message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=7ffad6d0-db78-8ffd-cc9d-7619e9359834, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=e4e5e571-581c-24e2-6d08-73bd1340d483, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'pmml1.0.bridge', message: GenericMessage [payload=byte[89], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=b325de8d-e28b-0c6c-e3e2-54e8ab22c66d, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888152}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - preSend on channel 'pmml1.1.bridge', message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.1, mqtt_duplicate=false, mqtt_qos=0, id=78a3106d-46cb-c3ac-f5df-8f1d1deb6c68, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - preSend on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 handler.LoggingHandler - org.springframework.integration.handler.LoggingHandler#0 received message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO xdbus.pmml1.1-1 sink.pmml1 - {"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - postSend (sent=true) on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - postSend (sent=true) on channel 'pmml1.1.bridge', message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.1, mqtt_duplicate=false, mqtt_qos=0, id=78a3106d-46cb-c3ac-f5df-8f1d1deb6c68, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
这是我的流定义-
xd:>stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy
创建并部署了新流'test'
当我尝试发布 JSON 数据时
{
"sepalLength": "6.4",
"sepalWidth": "3.2",
"petalLength": "4.5",
"petalWidth": "1.5"
}
通过代理获取错误。完整错误如下：-
2017-03-11T12:24:30+0530 1.3.1.RELEASE ERROR MQTT Call: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Unhandled exception for GenericMessage [payload={
"sepalLength": "6.4",
"sepalWidth": "3.2",
"petalLength": "4.5",
"petalWidth": "1.5"
}, headers={mqtt_retained=false, mqtt_qos=0, id=fa97c439-5896-dc53-6c4a-7a8af57b73de, mqtt_topic=irisPayload, mqtt_duplicate=false, timestamp=1489215270746}]
org.springframework.integration.transformer.MessageTransformationException: Failed to transform Message; nested exception is org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:95) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:99) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:231) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:154) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:102) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:231) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:154) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:102) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:147) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:120) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:442) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:392) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:105) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter.messageArrived(MqttPahoMessageDrivenChannelAdapter.java:314) ~[spring-integration-mqtt-4.2.5.RELEASE.jar!/:na]
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:354) [org.eclipse.paho.client.mqttv3-1.0.2.jar!/:na]
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:162) [org.eclipse.paho.client.mqttv3-1.0.2.jar!/:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101]
Caused by: org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:96) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.transformer.AbstractMessageProcessingTransformer.transform(AbstractMessageProcessingTransformer.java:90) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:89) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
... 44 common frames omitted
Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.xd.tuple.Tuple
at org.springframework.xd.analytics.ml.pmml.TuplePmmlAnalyticInputDataMapper.mapInput(TuplePmmlAnalyticInputDataMapper.java:37) ~[na:na]
at org.springframework.xd.analytics.ml.MappedAnalytic.evaluate(MappedAnalytic.java:64) ~[na:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_101]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_101]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_101]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_101]
at org.springframework.expression.spel.support.ReflectiveMethodExecutor.execute(ReflectiveMethodExecutor.java:113) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference.getValueInternal(MethodReference.java:102) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference.access[=14=]0(MethodReference.java:49) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.MethodReference$MethodValueRef.getValue(MethodReference.java:347) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.CompoundExpression.getValueInternal(CompoundExpression.java:88) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.ast.SpelNodeImpl.getTypedValue(SpelNodeImpl.java:131) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:330) ~[spring-expression-4.2.4.RELEASE.jar:4.2.4.RELEASE]
at org.springframework.integration.util.AbstractExpressionEvaluator.evaluateExpression(AbstractExpressionEvaluator.java:166) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.util.MessagingMethodInvokerHelper.processInternal(MessagingMethodInvokerHelper.java:317) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.util.MessagingMethodInvokerHelper.process(MessagingMethodInvokerHelper.java:155) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:93) ~[spring-integration-core-4.2.5.RELEASE.jar:na]
... 46 common frames omitted
2017-03-11T12:24:30+0530 1.3.1.RELEASE ERROR MQTT Call: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:MqttException; retrying...
非常感谢。这是更新错误日志消息，推荐后：
2017-03-12T00:21:11+0530 1.3.1.RELEASE ERROR MQTT Ping: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:Timed out waiting for a response from the server; retrying...
2017-03-12T00:25:02+0530 1.3.1.RELEASE ERROR MQTT Rec: xd.mqtt.client.id.src server.NIOServerCnxnFactory - Thread Thread[MQTT Rec: xd.mqtt.client.id.src,5,main] died
java.lang.NoClassDefFoundError: org/eclipse/paho/client/mqttv3/internal/wire/MqttReceivedMessage
at org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage.createWireMessage(MqttWireMessage.java:189) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage.createWireMessage(M qttWireMessage.java:163) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage (MqttInputStream.java:83) ~[na:na]
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:107 ) ~[na:na]
at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_101]
Caused by: java.lang.ClassNotFoundException: org.eclipse.paho.client.mqttv3.internal.wire.MqttReceivedMessage
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~ [na:1.8.0_101]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_101]
at org.springframework.xd.module.support.ParentLastURLClassLoader.loadClass(ParentL astURLClassLoader.java:87) ~[spring-xd-module- 1.3.1.RELEASE.jar:1.3.1.RELEASE]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_101]
... 5 common frames omitted
2017-03-12T00:26:11+0530 1.3.1.RELEASE ERROR MQTT Ping: xd.mqtt.client.id.src inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:Timed out waiting for a response from the server; retrying...
pmml 模块需要 Tuple - 尝试将 --outputType=application/x-xd-tuple 添加到 mqtt 源定义
xd:>stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload' --outputType=application/x-xd-tuple | analytic-pmml ...
编辑
我用 TCP 源测试了它...
xd:>stream create --name pmml1 --definition "tcp --outputType=application/x-xd-tuple | analytic-pmml --modelName=iris-flower-classification-naive-bayes-1 --location=/Users/grussell/Downloads/spring-xd-modules-master/analytics-ml-pmml/src/test/resources/analytics/pmml/iris-flower-classification-naive-bayes-1.pmml.xml --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width' --outputFieldMapping='Predicted_Species:predictedSpecies' | log" --deploy
并使用telnet localhost 1234发送：
{ "sepalLength": 6.4, "sepalWidth": 3.2, "petalLength":4.5, "petalWidth":1.5 }
而且效果很好。
EDIT2
我刚用 MQTT 测试过，没问题...
2017-03-11T11:25:58-0500 1.3.1.RELEASE INFO xdbus.pmml1.1-1 sink.pmml1 -
{"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}
流：
xd:>stream create --name pmml1 --definition "mqtt --topics=pmml --outputType=application/x-xd-tuple | analytic-pmml --modelName=iris-flower-classification-naive-bayes-1 --location=/Users/grussell/Downloads/spring-xd-modules-master/analytics-ml-pmml/src/test/resources/analytics/pmml/iris-flower-classification-naive-bayes-1.pmml.xml --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width' --outputFieldMapping='Predicted_Species:predictedSpecies' | log" --deploy
EDIT3
这是我测试的 DEBUG 日志（针对 logback.groovy 中的类别 org.springframework.integration）；我建议你把你的和这个比较一下，看看哪里出了问题...
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src channel.DirectChannel - preSend on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=a4f09671-c617-bfce-c2f7-e1844a8772ff, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888127}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [41, org.springframework.xd.tuple.DefaultTuple] with serializer org.springframework.xd.tuple.serializer.kryo.DefaultTupleSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO MQTT Call: xd.mqtt.client.id.src kryo.CompositeKryoRegistrar - registering [42, java.util.ArrayList] with serializer com.esotericsoftware.kryo.serializers.CollectionSerializer
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src outbound.AmqpOutboundEndpoint - org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@2cc14cf received message: GenericMessage [payload=byte[89], headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=58499b9d-6a38-ea36-ac8e-93c704d61a1b, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888135}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src outbound.AmqpOutboundEndpoint - handler 'org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@2cc14cf' produced no reply for request Message: GenericMessage [payload=byte[89], headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=58499b9d-6a38-ea36-ac8e-93c704d61a1b, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888135}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG MQTT Call: xd.mqtt.client.id.src channel.DirectChannel - postSend (sent=true) on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={mqtt_duplicate=false, mqtt_retained=false, mqtt_qos=0, id=a4f09671-c617-bfce-c2f7-e1844a8772ff, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888127}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'pmml1.0.bridge', message: GenericMessage [payload=byte[89], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=b325de8d-e28b-0c6c-e3e2-54e8ab22c66d, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888152}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 transformer.MessageTransformingHandler - org.springframework.integration.config.TransformerFactoryBean#0 received message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - preSend on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=e4e5e571-581c-24e2-6d08-73bd1340d483, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 outbound.AmqpOutboundEndpoint - org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6c6a8365 received message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=7ffad6d0-db78-8ffd-cc9d-7619e9359834, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_consumerQueue] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_consumerTag] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 outbound.AmqpOutboundEndpoint - handler 'org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6c6a8365' produced no reply for request Message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=7ffad6d0-db78-8ffd-cc9d-7619e9359834, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'output', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=e4e5e571-581c-24e2-6d08-73bd1340d483, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888276}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5}, headers={amqp_receivedRoutingKey=xdbus.pmml1.0, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, mqtt_qos=0, id=62a6601c-d4db-8e33-ab97-1e5ffd17a56f, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888166}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.0-1 channel.DirectChannel - postSend (sent=true) on channel 'pmml1.0.bridge', message: GenericMessage [payload=byte[89], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.0, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.0, mqtt_duplicate=false, mqtt_qos=0, id=b325de8d-e28b-0c6c-e3e2-54e8ab22c66d, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-rXY4nOqwizbePkGVpCulcg, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888152}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_receivedRoutingKey] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_deliveryTag] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[amqp_redelivered] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_duplicate] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_retained] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_qos] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[mqtt_topic] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[contentType] WILL be mapped, found in [amqp_appId, amqp_clusterId, amqp_contentEncoding, amqp_contentLength, contentType, amqp_correlationId, amqp_deliveryMode, amqp_deliveryTag, amqp_expiration, amqp_messageCount, amqp_messageId, amqp_receivedExchange, amqp_receivedRoutingKey, amqp_redelivered, amqp_replyTo, amqp_timestamp, amqp_type, amqp_userId, json__TypeId__, json__ContentTypeId__, json__KeyTypeId__, amqp_springReplyCorrelation, amqp_springReplyToStack]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 mapping.AbstractHeaderMapper$HeaderMatcher - headerName=[originalContentType] WILL be mapped, matched pattern=*
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - preSend on channel 'pmml1.1.bridge', message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.1, mqtt_duplicate=false, mqtt_qos=0, id=78a3106d-46cb-c3ac-f5df-8f1d1deb6c68, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - preSend on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 handler.LoggingHandler - org.springframework.integration.handler.LoggingHandler#0 received message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE INFO xdbus.pmml1.1-1 sink.pmml1 - {"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - postSend (sent=true) on channel 'input', message: GenericMessage [payload={"sepalLength":6.4,"sepalWidth":3.2,"petalLength":4.5,"petalWidth":1.5,"predictedSpecies":"versicolor"}, headers={amqp_receivedRoutingKey=xdbus.pmml1.1, amqp_deliveryTag=1, mqtt_duplicate=false, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, mqtt_qos=0, id=7d15c204-5ee1-600d-3bda-45abf7059dac, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]
2017-03-11T12:38:08-0500 1.3.1.RELEASE DEBUG xdbus.pmml1.1-1 channel.DirectChannel - postSend (sent=true) on channel 'pmml1.1.bridge', message: GenericMessage [payload=byte[119], headers={amqp_deliveryTag=1, mqtt_retained=false, amqp_consumerQueue=xdbus.pmml1.1, amqp_redelivered=false, originalContentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, amqp_receivedRoutingKey=xdbus.pmml1.1, mqtt_duplicate=false, mqtt_qos=0, id=78a3106d-46cb-c3ac-f5df-8f1d1deb6c68, mqtt_topic=mqtt-subscription-xd/mqtt/client/id/srcqos0, amqp_consumerTag=amq.ctag-Jjdp9-tezFirzMm72oL8kA, contentType=application/x-java-object;type=org.springframework.xd.tuple.DefaultTuple, timestamp=1489253888279}]