API tools faq
paste
Guest User

Untitled

a guest
Nov 19th, 2018
92
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 8.08 KB | None | 0 0
raw download clone embed print report
  1. @Bean
  2. public IntegrationFlow lambda(MessageChannel outputChannel) {
  3. return f -> f
  4. .enrichHeaders(h -> h.header("add", 1))
  5. .<Message<Integer>, Integer>transform(m -> m.getPayload() + m.getHeaders().get("add", Integer.class))
  6. .channel(outputChannel);
  7. }
  8.  
  9. @Bean
  10. public IntegrationFlow anonymous(MessageChannel outputChannel) {
  11. return f -> f
  12. .enrichHeaders(h -> h.header("add", 1))
  13. .transform(new GenericTransformer<Message<Integer>, Integer>() {
  14. @Override
  15. public Integer transform(Message<Integer> source) {
  16. return source.getPayload() + source.getHeaders().get("add", Integer.class);
  17. }
  18. })
  19. .channel(outputChannel);
  20. }
  21.  
  22. org.springframework.integration.transformer.MessageTransformationException: Failed to transform Message; nested exception is org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.Integer cannot be cast to org.springframework.messaging.Message, failedMessage=GenericMessage [payload=0, headers={add=1, id=ed1e39d9-a91b-0bdf-5083-48218ba4e26f, timestamp=1542652005152}], failedMessage=GenericMessage [payload=0, headers={add=1, id=ed1e39d9-a91b-0bdf-5083-48218ba4e26f, timestamp=1542652005152}]
  23. at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:114)
  24. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:123)
  25. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:169)
  26. at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115)
  27. at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133)
  28. at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106)
  29. at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:73)
  30. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:459)
  31. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:400)
  32. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187)
  33. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166)
  34. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47)
  35. at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)
  36. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:415)
  37. at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:334)
  38. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:225)
  39. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:129)
  40. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:169)
  41. at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115)
  42. at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133)
  43. at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106)
  44. at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:73)
  45. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:459)
  46. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:400)
  47. at org.example.LambdaVsAnonymousTest.lambda(LambdaVsAnonymousTest.java:39)
  48. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  49. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  50. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  51. at java.lang.reflect.Method.invoke(Method.java:498)
  52. at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
  53. at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
  54. at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
  55. at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
  56. at org.springframework.test.context.junit4.statements.RunBeforeTestExecutionCallbacks.evaluate(RunBeforeTestExecutionCallbacks.java:74)
  57. at org.springframework.test.context.junit4.statements.RunAfterTestExecutionCallbacks.evaluate(RunAfterTestExecutionCallbacks.java:84)
  58. at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
  59. at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
  60. at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
  61. at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
  62. at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:251)
  63. at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
  64. at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
  65. at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
  66. at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
  67. at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
  68. at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
  69. at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
  70. at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
  71. at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
  72. at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
  73. at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
  74. at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
  75. at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:538)
  76. at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:760)
  77. at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:460)
  78. at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:206)
  79. Caused by: org.springframework.messaging.MessageHandlingException: nested exception is java.lang.ClassCastException: java.lang.Integer cannot be cast to org.springframework.messaging.Message, failedMessage=GenericMessage [payload=0, headers={add=1, id=ed1e39d9-a91b-0bdf-5083-48218ba4e26f, timestamp=1542652005152}]
  80. at org.springframework.integration.handler.LambdaMessageProcessor.processMessage(LambdaMessageProcessor.java:125)
  81. at org.springframework.integration.transformer.AbstractMessageProcessingTransformer.transform(AbstractMessageProcessingTransformer.java:113)
  82. at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:108)
  83. ... 55 more
  84. Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to org.springframework.messaging.Message
  85. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  86. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  87. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  88. at java.lang.reflect.Method.invoke(Method.java:498)
  89. at org.springframework.integration.handler.LambdaMessageProcessor.processMessage(LambdaMessageProcessor.java:122)
  90. ... 57 more
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!