Advertisement
Guest User

Untitled

a guest
Mar 30th, 2017
97
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.84 KB | None | 0 0
  1. public interface MessageChanelInterface {
  2.  
  3. String DEVICE_SINK = "device-sink";
  4.  
  5. @Input(DEVICE_SINK)
  6. SubscribableChannel receiveDeviceEvent();}
  7.  
  8. @Service
  9. public class SubscriberToDevice {
  10.  
  11. @Autowired
  12. ParkingService parkingService;
  13.  
  14. @StreamListener(MessageChanelInterface.DEVICE_SINK)
  15. public void receiveDeviceEvent(Object event) {
  16. //Some code what to do with event.
  17. }
  18. }
  19.  
  20. @Configuration
  21.  
  22. @EnableBinding(MessageChanelInterface.class)
  23.  
  24. public class MessageChanelConfiguration {
  25.  
  26. }
  27.  
  28. spring.cloud.stream.binders.rabbit1.type=rabbit
  29. spring.cloud.stream.binders.rabbit1.environment.spring.rabbitmq.addresses=${_rabbit.host}
  30. spring.cloud.stream.binders.rabbit1.environment.spring.rabbitmq.port=5672
  31. spring.cloud.stream.binders.rabbit1.environment.spring.rabbitmq.username=${_rabbit.username}
  32. spring.cloud.stream.binders.rabbit1.environment.spring.rabbitmq.password=${_rabbit.password}
  33. spring.cloud.stream.bindings.device-sink.binder=rabbit1
  34. spring.cloud.stream.bindings.device-sink.destination=device
  35. spring.cloud.stream.bindings.device-sink.group=group-${spring.application.name}
  36.  
  37. spring.cloud.stream.bindings.device-source.binder=rabbit1
  38. spring.cloud.stream.bindings.device-source.destination=device
  39.  
  40. org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception
  41. at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.wrapToListenerExecutionFailedExceptionIfNeeded(AbstractMessageListenerContainer.java:877)
  42. at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:787)
  43. at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:707)
  44. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$001(SimpleMessageListenerContainer.java:98)
  45. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$1.invokeListener(SimpleMessageListenerContainer.java:189)
  46. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  47. at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
  48. at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
  49. at java.lang.reflect.Method.invoke(Unknown Source)
  50. at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
  51. at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
  52. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  53. at org.springframework.retry.interceptor.RetryOperationsInterceptor$1.doWithRetry(RetryOperationsInterceptor.java:74)
  54. at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:276)
  55. at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:172)
  56. at org.springframework.retry.interceptor.RetryOperationsInterceptor.invoke(RetryOperationsInterceptor.java:98)
  57. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  58. at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
  59. at com.sun.proxy.$Proxy195.invokeListener(Unknown Source)
  60. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.invokeListener(SimpleMessageListenerContainer.java:1236)
  61. at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:688)
  62. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1190)
  63. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:1174)
  64. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$1200(SimpleMessageListenerContainer.java:98)
  65. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1363)
  66. at java.lang.Thread.run(Unknown Source)
  67. Caused by: org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'parkingspace:default:8096.device-sink'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=EventOccupationDetected [parkingSpaceID=141AA061-86C4-8518-03EC-39C0F6F99AE0], headers={amqp_receivedDeliveryMode=PERSISTENT, amqp_receivedRoutingKey=device, amqp_receivedExchange=device, amqp_deliveryTag=1, correlation-id=85687a94-9bcd-48bb-bfc4-765546b32996, amqp_consumerQueue=device.group-parkingspace, amqp_redelivered=false, id=01d247a7-b37b-2d79-4b90-f59812d25f4b, amqp_consumerTag=amq.ctag-qSSn_-Zw481_KxEz-pbjUQ, contentType=application/x-java-object;type=sk.posam.sp.device.domain.event.EventOccupationDetected, timestamp=1490874431951}]
  68. at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:93)
  69. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423)
  70. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:373)
  71. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)
  72. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)
  73. at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)
  74. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:292)
  75. at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:212)
  76. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:129)
  77. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:115)
  78. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
  79. at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:70)
  80. at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:64)
  81. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)
  82. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)
  83. at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)
  84. at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:171)
  85. at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$400(AmqpInboundChannelAdapter.java:45)
  86. at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$1.onMessage(AmqpInboundChannelAdapter.java:95)
  87. at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:784)
  88. ... 24 common frames omitted
  89. Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers
  90. at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:154)
  91. at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)
  92. at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:89)
  93. ... 43 common frames omitted
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement