public class XmppConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.jivesoftware.smack.chat2.IncomingChatMessageListener, org.jivesoftware.smack.MessageListener, org.jivesoftware.smack.StanzaListener
Consumer
which listens to XMPP packetsConstructor and Description |
---|
XmppConsumer(XmppEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
newIncomingMessage(org.jxmpp.jid.EntityBareJid from,
org.jivesoftware.smack.packet.Message message,
org.jivesoftware.smack.chat2.Chat chat) |
void |
processMessage(org.jivesoftware.smack.chat2.Chat chat,
org.jivesoftware.smack.packet.Message message) |
void |
processMessage(org.jivesoftware.smack.packet.Message message) |
void |
processStanza(org.jivesoftware.smack.packet.Stanza stanza) |
protected void |
scheduleDelayedStart() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public XmppConsumer(XmppEndpoint endpoint, org.apache.camel.Processor processor)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
public void newIncomingMessage(org.jxmpp.jid.EntityBareJid from, org.jivesoftware.smack.packet.Message message, org.jivesoftware.smack.chat2.Chat chat)
newIncomingMessage
in interface org.jivesoftware.smack.chat2.IncomingChatMessageListener
public void processMessage(org.jivesoftware.smack.packet.Message message)
processMessage
in interface org.jivesoftware.smack.MessageListener
public void processStanza(org.jivesoftware.smack.packet.Stanza stanza) throws org.jivesoftware.smack.SmackException.NotConnectedException, InterruptedException
processStanza
in interface org.jivesoftware.smack.StanzaListener
org.jivesoftware.smack.SmackException.NotConnectedException
InterruptedException
public void processMessage(org.jivesoftware.smack.chat2.Chat chat, org.jivesoftware.smack.packet.Message message)
Apache Camel