You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2008/07/12 07:05:51 UTC

svn commit: r676127 - /activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java

Author: hadrian
Date: Fri Jul 11 22:05:50 2008
New Revision: 676127

URL: http://svn.apache.org/viewvc?rev=676127&view=rev
Log:
CAMEL-704.  Patch applied with thatnks!

Modified:
    activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java

Modified: activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java?rev=676127&r1=676126&r2=676127&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java (original)
+++ activemq/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java Fri Jul 11 22:05:50 2008
@@ -20,7 +20,7 @@
 import org.apache.camel.impl.DefaultProducer;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.jivesoftware.smack.GroupChat;
+import org.jivesoftware.smackx.muc.MultiUserChat;
 import org.jivesoftware.smack.XMPPException;
 import org.jivesoftware.smack.packet.Message;
 
@@ -31,7 +31,7 @@
     private static final transient Log LOG = LogFactory.getLog(XmppGroupChatProducer.class);
     private final XmppEndpoint endpoint;
     private final String room;
-    private GroupChat chat;
+    private MultiUserChat chat;
 
     public XmppGroupChatProducer(XmppEndpoint endpoint, String room) {
         super(endpoint);
@@ -63,7 +63,8 @@
     protected void doStart() throws Exception {
         super.doStart();
         if (chat == null) {
-            chat = endpoint.getConnection().createGroupChat(room);
+        	chat = new MultiUserChat(endpoint.getConnection(), room);
+        	chat.join(this.endpoint.getResource());
         }
     }
 
@@ -78,11 +79,11 @@
 
     // Properties
     // -------------------------------------------------------------------------
-    public GroupChat getChat() {
+    public MultiUserChat getChat() {
         return chat;
     }
 
-    public void setChat(GroupChat chat) {
+    public void setChat(MultiUserChat chat) {
         this.chat = chat;
     }