You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/06/10 06:56:11 UTC
svn commit: r783204 -
/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
Author: davsclaus
Date: Wed Jun 10 04:56:10 2009
New Revision: 783204
URL: http://svn.apache.org/viewvc?rev=783204&view=rev
Log:
CAMEL-1633: xmpp consumer should only handle Message packets.
Modified:
camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
Modified: camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java?rev=783204&r1=783203&r2=783204&view=diff
==============================================================================
--- camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java (original)
+++ camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java Wed Jun 10 04:56:10 2009
@@ -100,8 +100,12 @@
}
public void processPacket(Packet packet) {
- Message message = (Message) packet;
+ if (packet instanceof Message) {
+ processMessage(null, (Message) packet);
+ }
+ }
+ public void processMessage(Chat chat, Message message) {
if (LOG.isDebugEnabled()) {
LOG.debug("Recieved XMPP message: " + message.getBody());
}
@@ -114,8 +118,4 @@
}
}
- public void processMessage(Chat chat, Message message) {
- processPacket(message);
- }
-
}