스프링 통합 websocket "outputChannel"또는 "outputChannelName"이 필요합니다. 예외 "

Question

저는 Spring 통합 프레임 워크를 처음 사용합니다. 스프링 통합 웹 소켓 샘플 code을 실행하는 동안 'outputChannel'또는 'outputChannelName'이 필요합니다. 예외입니다.

내가 무엇을 놓쳤습니까? 다음

내 코드는,

@Configuration 
@ComponentScan 
@EnableAutoConfiguration 
@RestController 
public class Application { 

    public static void main(String args[]) throws Throwable { 
     SpringApplication.run(Application.class, args); 
    } 

    @Bean 
    ServerWebSocketContainer serverWebSocketContainer() { 
     return new ServerWebSocketContainer("/names").withSockJs(); 
    } 

    @Bean 
    MessageHandler webSocketOutboundAdapter() { 
     return new WebSocketOutboundMessageHandler(serverWebSocketContainer()); 
    } 

    @Bean(name = "webSocketFlow.input") 
    MessageChannel requestChannel() { 
     return new DirectChannel(); 
    } 

    @Bean 
    IntegrationFlow webSocketFlow() { 
     return f -> { 
      Function<Message, Object> splitter = m -> serverWebSocketContainer().getSessions().keySet().stream() 
        .map(s -> MessageBuilder.fromMessage(m).setHeader(SimpMessageHeaderAccessor.SESSION_ID_HEADER, s).build()).collect(Collectors.toList()); 
      f.split(Message.class, splitter).channel(c -> c.executor(Executors.newCachedThreadPool())).handle(webSocketOutboundAdapter()); 
     }; 
    } 

    @RequestMapping("/hi/{name}") 
    public void send(@PathVariable String name) { 
     requestChannel().send(MessageBuilder.withPayload(name).build()); 
    } 
} 

예외 스택,

java.lang.IllegalStateException: 'outputChannel' or 'outputChannelName' is required 
    at org.springframework.util.Assert.state(Assert.java:70) 
    at org.springframework.integration.endpoint.MessageProducerSupport.afterSingletonsInstantiated(MessageProducerSupport.java:153) 
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:781) 
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867) 

Answer 1

java.lang.IllegalStateException: 'outputChannel' or 'outputChannelName' is required 
at org.springframework.util.Assert.state(Assert.java:70) 
at org.springframework.integration.endpoint.MessageProducerSupport.afterSingletonsInstantiated(MessageProducerSupport.java:153) 

에주의 - MessageProducerSupport. 코드에 어떤 내용도 표시되지 않으므로 응용 프로그램에서 무언가를 숨길 수 있습니다. setOutputChannel()로 선언해야

@Bean 
public WebSocketInboundChannelAdapter webSocketInboundChannelAdapter() { 
    ... 
} 

그리고 정확히 하나

는 그리고 난 당신이 뭔가를 할 수도 있습니다 같아요.

또는 자바 DSL - IntegrationFlows.from(webSocketInboundChannelAdapter())에서 시작점으로 사용하는 경우 - @Bean으로 선언하지 마십시오. 프레임 워크는 이후에 적절한 구성과 등록을 처리합니다.