XMPP의 봄 통합 - 내가 듣고 XMPP를 사용하여 메시지를 보낼 봄 부팅에서 서버를 만들려고, XMPP 새로운 오전

Question

채팅이 내가 뭘하려

의 context.xml

<?xml version="1.0" encoding="UTF-8"?> 
<beans:beans xmlns="http://www.springframework.org/schema/integration" 
    xmlns:beans="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:int-xmpp="http://www.springframework.org/schema/integration/xmpp" 
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans.xsd 
    http://www.springframework.org/schema/integration/xmpp 
    http://www.springframework.org/schema/integration/xmpp/spring-integration-xmpp.xsd"> 

    <int-xmpp:xmpp-connection 
     id="xmppConnection" 
     user="admin@192.168.1.201" 
     password="finatel123" 
     host="192.168.1.201" 
     port="5222"/> 

    <int-xmpp:inbound-channel-adapter 
     id="xmppInboundAdapter" 
     channel="chatMessageListening" 
     xmpp-connection="xmppConnection" 
     auto-startup="true"/> 

    <int-xmpp:outbound-channel-adapter 
     id="outboundEventAdapter" 
     channel="chatMessageSending" 
     xmpp-connection="xmppConnection" 
     auto-startup="false"> 
     <poller fixed-rate="5000" max-messages-per-poll="1"/> 
    </int-xmpp:outbound-channel-adapter> 

</beans:beans> 

ChatMessageListening.java

public class ChatMessageListening implements MessageChannel { 

    @Override 
    public boolean send(Message<?> message) { 

     MessageHeaders headers = message.getHeaders(); 

     System.out.println("FROM : "+headers.get(XmppHeaders.FROM)); 
     System.out.println("TO  : "+headers.get(XmppHeaders.TO)); 
     System.out.println("Time : "+new Date((Long)headers.get("timestamp"))); 

     return true; 
    } 

    @Override 
    public boolean send(Message<?> message, long timeout) { 
     return true; 
    } 
} 

ChatMessageSending.java

public class ChatMessageSending implements PollableChannel { 

    @Override 
    public boolean send(Message<?> message) { 
     return true; 
    } 

    @Override 
    public boolean send(Message<?> message, long timeout) { 
     return true; 
    } 

    @Override 
    public Message<?> receive() { 
     return null; 
    } 

    @Override 
    public Message<?> receive(long timeout) { 
      return null; 
    } 
} 

이 구성을 수행하면 ChatMessageListening.send() 방법으로 메시지를 수신 할 수 있습니다.

나는 사용하여 메시지를 보낼 수

MessagingTemplate template = new MessagingTemplate(); 
template.setSendTimeout(5000L); 

Message<String> xmppOutboundMsg = MessageBuilder.withPayload("Hello, XMPP!") 
    .setHeader(XmppHeaders.FROM, "admin@192.168.1.201") 
    .setHeader(XmppHeaders.TO, "adminone@192.168.1.201") 
    .setHeader(XmppHeaders.TYPE, "chat") 
    .build(); 
template.setDefaultChannel(new ChatMessageSending()); 
template.send(xmppOutboundMsg); 

을 시도하지만 클라이언트에 전송되지 않고는 ChatMessageSending에 수신. 내가 뭘 잘못하고 있는지 안내해 줘. 내가 사용해야하는 것.

Answer 1

이상한 방법으로 MessageChannel을 사용합니다.

이 문제에 대한 귀하의 비전을 수정하는 것을 고려하십시오 : EIP definition와 Spring 통합 implementation :

생산자는 채널에 메시지를 전송하고, 소비자는 채널에서 메시지를받을 수 있습니다.

따라서 메시지 채널은 listener 일 수 없으며 sending과 같을 수 없습니다.

구성에 <channel> 몇 개를 선언하고 적절한 <service-activator>을 사용하여 XMPP 및 일부 다른 메시지를 처리하여 메시지를 생성해야합니다.

예, MessagingTemplate은 송신에 사용할 수 있지만 <int-xmpp:outbound-channel-adapter>이 구독자 인 적절한 MessageChannel 콩을 지적해야합니다.

지금 ChatMessageSending에는 void 구현이 있으며 대상 채널 어댑터와의 연결이 없습니다.

그런데 XMPP sample이 있습니다.