From 1b86318f934d5d819c69644fc8450210f04e281f Mon Sep 17 00:00:00 2001 From: Johan Pramming Date: Wed, 20 Nov 2019 01:32:34 +0100 Subject: [PATCH] CAMEL-14194: Message thread name removed from JID --- .../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 4bf2197b21a40..88a0dda564390 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 @@ -79,7 +79,7 @@ public void process(Exchange exchange) { 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); @@ -93,9 +93,9 @@ public void process(Exchange exchange) { } } - 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 {