春雲流卡夫卡：「調度員沒有訂戶」錯誤

我與卡夫卡粘結劑測試春季雲流，但得到了一個錯誤春雲流卡夫卡：「調度員沒有訂戶」錯誤

產生的原因：org.springframework.messaging.MessageDeliveryException：調度員有沒有訂戶頻道'unknown.channel.name'。;

的pom.xml

<parent> 
    <groupId>org.springframework.boot</groupId> 
    <artifactId>spring-boot-starter-parent</artifactId> 
    <version>1.4.0.RELEASE</version> 
</parent> 

<dependencies> 
    <dependency> 
     <groupId>org.springframework.cloud</groupId> 
     <artifactId>spring-cloud-stream</artifactId> 
     <version>1.1.2.RELEASE</version> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.cloud</groupId> 
     <artifactId>spring-cloud-stream-binder-kafka</artifactId> 
     <version>1.1.2.RELEASE</version> 
    </dependency> 
</dependencies>

的玩具應用程序是模仿誰轉移員工和老闆之間的請求祕書。

爲僱員接口：

public interface SecretaryServingEmployee { 
    @Output 
    MessageChannel inbox(); 

    @Input 
    SubscribableChannel rejected(); 

    @Input 
    SubscribableChannel approved(); 

}

爲凸臺接口：

public interface SecretaryServingBoss { 
@Input 
SubscribableChannel inbox(); 

@Output 
MessageChannel rejected(); 

@Output 
MessageChannel approved();  
}

application.properties

server.port=8080 
spring.cloud.stream.bindings.inbox.destination=inbox 
spring.cloud.stream.bindings.approved.destination=approved 
spring.cloud.stream.bindings.rejected.destination=rejected

Employee.java

@EnableBinding(SecretaryServingEmployee.class) 
@Component 
public class Employee { 
    private static Logger logger = LoggerFactory.getLogger(Employee.class); 

    private SecretaryServingEmployee adminAssistent; 

    @Autowired 
    public Employee(SecretaryServingEmployee adminAssistent) { 
     this.adminAssistent = adminAssistent; 
    } 

    @InboundChannelAdapter(value = "inbox") 
    public String messageSource() { 
     return "You are handsome!!"; // This is the message sent to boss 
    } 

    @ServiceActivator(inputChannel="approved") 
    public void checkApproved(String message) { 
     logger.info(":-)"); 
    } 

    @ServiceActivator(inputChannel="rejected") 
    public void checkRejected(RejectionLetter letter) { 
     logger.warn(":-("); 
    } 
}

Boss.java

@EnableBinding(SecretaryServingBoss.class) 
@Component 
public class Boss { 
    private SecretaryServingBoss adminAssistent; 

    @Autowired 
    public Boss(SecretaryServingBoss adminAssistent) { 
     this.adminAssistent = adminAssistent; 
    } 

    @ServiceActivator(inputChannel="inbox") 
    public void sign(String content) { 
     if (content.contains("You are handsome")) { 
      adminAssistent.approved().send(message("nice work")); 
     } 
     else { 
      adminAssistent.rejected().send(message("Don't send me shit")); 
     }  
    } 

    private <T> Message<T> message(T content) { 
     return MessageBuilder.withPayload(content).build(); 
    } 

}

這是跟蹤

org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'unknown.channel.name'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers 
    at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:81) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:373) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:292) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:212) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:129) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:115) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:70) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:64) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105) ~[spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE] 
    at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:171) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$000(KafkaMessageDrivenChannelAdapter.java:47) ~[spring-integration-kafka-2.0.1.RELEASE.jar:na] 
    at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:197) ~[spring-integration-kafka-2.0.1.RELEASE.jar:na] 
    at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:76) ~[spring-kafka-1.0.5.RELEASE.jar:na] 
    at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:71) ~[spring-kafka-1.0.5.RELEASE.jar:na] 
    at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:276) ~[spring-retry-1.1.3.RELEASE.jar:na] 
    at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:172) ~[spring-retry-1.1.3.RELEASE.jar:na] 
    at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter.onMessage(RetryingAcknowledgingMessageListenerAdapter.java:71) ~[spring-kafka-1.0.5.RELEASE.jar:na] 
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:597) [spring-kafka-1.0.5.RELEASE.jar:na] 
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.access$1800(KafkaMessageListenerContainer.java:222) [spring-kafka-1.0.5.RELEASE.jar:na] 
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer$ListenerInvoker.run(KafkaMessageListenerContainer.java:772) [spring-kafka-1.0.5.RELEASE.jar:na] 
    at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) [na:1.8.0_121] 
    at java.util.concurrent.FutureTask.run(Unknown Source) [na:1.8.0_121] 
    at java.lang.Thread.run(Unknown Source) [na:1.8.0_121] 
Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers 
    at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:154) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) ~[spring-integration-core-4.3.1.RELEASE.jar:4.3.1.RELEASE] 
    ... 29 common frames omitted

來源

2017-04-17 ccshih

它看起來的一部分，就像你的應用程序類不是組件掃描正常。

如果您將此作爲Spring Boot應用程序運行，您是否可以確定是否將要掃描的類打包正確。

例如，默認情況下，@SpringBootApplication的組件掃描查看@SpringBootApplication註釋類所在的相同包中的類。

來源

2017-04-17 09:19:02

是的，它是一個Spring Boot應用程序，所有的代碼都在一個包中。 – ccshih

你不需要每個人的唯一目的地名稱？例如'@Input（「bossInbox」）'等 –

唯一的目的地名稱解決了問題。謝謝你，@加里·羅素 – ccshih

春雲流卡夫卡：「調度員沒有訂戶」錯誤

回答

相關問題