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

[hadrian]

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;
     }