[camel] branch camel-2.x updated: CAMEL-14194: Message thread name removed from JID (#3351)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.x by this push:
     new 8235334  CAMEL-14194: Message thread name removed from JID (#3351)
8235334 is described below

commit 82353344f6224d68df5ff79b05c45917d11755b0
Author: Johan Pramming <johanpramm...@outlook.com>
AuthorDate: Wed Nov 20 05:17:18 2019 +0100

    CAMEL-14194: Message thread name removed from JID (#3351)
---
 .../org/apache/camel/component/xmpp/XmppPrivateChatProducer.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java
 
b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java
index b1b30a1..2bd599b 100644
--- 
a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java
+++ 
b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java
@@ -81,7 +81,7 @@ public class XmppPrivateChatProducer extends DefaultProducer {
             message.setType(Message.Type.normal);
 
             ChatManager chatManager = ChatManager.getInstanceFor(connection);
-            Chat chat = getOrCreateChat(chatManager, participant, thread);
+            Chat chat = getOrCreateChat(chatManager, participant);
 
             endpoint.getBinding().populateXmppMessage(message, exchange);
 
@@ -95,9 +95,9 @@ public class XmppPrivateChatProducer extends DefaultProducer {
         }
     }
 
-    private Chat getOrCreateChat(ChatManager chatManager, final String 
participant, String thread) throws XmppStringprepException {
+    private Chat getOrCreateChat(ChatManager chatManager, final String 
participant) throws XmppStringprepException {
         // this starts a new chat or retrieves the pre-existing one in a 
threadsafe manner
-        return chatManager.chatWith(JidCreate.entityBareFrom(participant + "@" 
+ thread));
+        return chatManager.chatWith(JidCreate.entityBareFrom(participant));
     }
 
     private synchronized void reconnect() throws InterruptedException, 
IOException, SmackException, XMPPException {