Package org.apache.camel.component.xmpp
Class XmppConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.apache.camel.component.xmpp.XmppConsumer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
,org.jivesoftware.smack.chat2.IncomingChatMessageListener
,org.jivesoftware.smack.MessageListener
,org.jivesoftware.smack.StanzaListener
public class XmppConsumer extends org.apache.camel.support.DefaultConsumer implements org.jivesoftware.smack.chat2.IncomingChatMessageListener, org.jivesoftware.smack.MessageListener, org.jivesoftware.smack.StanzaListener
AConsumer
which listens to XMPP packets
-
-
Constructor Summary
Constructors Constructor Description XmppConsumer(XmppEndpoint endpoint, org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
Methods inherited from class org.apache.camel.support.DefaultConsumer
createUoW, doInit, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
XmppConsumer
public XmppConsumer(XmppEndpoint endpoint, org.apache.camel.Processor processor)
-
-
Method Detail
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
newIncomingMessage
public void newIncomingMessage(org.jxmpp.jid.EntityBareJid from, org.jivesoftware.smack.packet.Message message, org.jivesoftware.smack.chat2.Chat chat)
- Specified by:
newIncomingMessage
in interfaceorg.jivesoftware.smack.chat2.IncomingChatMessageListener
-
processMessage
public void processMessage(org.jivesoftware.smack.packet.Message message)
- Specified by:
processMessage
in interfaceorg.jivesoftware.smack.MessageListener
-
processStanza
public void processStanza(org.jivesoftware.smack.packet.Stanza stanza) throws org.jivesoftware.smack.SmackException.NotConnectedException, InterruptedException
- Specified by:
processStanza
in interfaceorg.jivesoftware.smack.StanzaListener
- Throws:
org.jivesoftware.smack.SmackException.NotConnectedException
InterruptedException
-
processMessage
public void processMessage(org.jivesoftware.smack.chat2.Chat chat, org.jivesoftware.smack.packet.Message message)
-
-