public class XmppConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.jivesoftware.smack.PacketListener, org.jivesoftware.smack.MessageListener, org.jivesoftware.smack.ChatManagerListener
Consumer
which listens to XMPP packetsConstructor and Description |
---|
XmppConsumer(XmppEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
void |
chatCreated(org.jivesoftware.smack.Chat chat,
boolean createdLocally) |
protected void |
doStart() |
protected void |
doStop() |
void |
processMessage(org.jivesoftware.smack.Chat chat,
org.jivesoftware.smack.packet.Message message) |
void |
processPacket(org.jivesoftware.smack.packet.Packet packet) |
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 chatCreated(org.jivesoftware.smack.Chat chat, boolean createdLocally)
chatCreated
in interface org.jivesoftware.smack.ChatManagerListener
public void processPacket(org.jivesoftware.smack.packet.Packet packet)
processPacket
in interface org.jivesoftware.smack.PacketListener
public void processMessage(org.jivesoftware.smack.Chat chat, org.jivesoftware.smack.packet.Message message)
processMessage
in interface org.jivesoftware.smack.MessageListener
Apache Camel