Class ChatMessageListeningEndpoint
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareEndpoint
org.springframework.integration.xmpp.inbound.ChatMessageListeningEndpoint
- All Implemented Interfaces:
Aware
,BeanFactoryAware
,BeanNameAware
,DisposableBean
,InitializingBean
,SmartInitializingSingleton
,ApplicationContextAware
,Lifecycle
,Phased
,SmartLifecycle
,ExpressionCapable
,MessageProducer
,IntegrationPattern
,NamedComponent
,ManageableLifecycle
,ManageableSmartLifecycle
,TrackableComponent
This component logs in as a user and forwards any messages to that
user on to downstream components.
- Since:
- 2.0
- Author:
- Josh Long, Mark Fisher, Oleg Zhurakousky, Artem Bilan, Gary Russell
-
Field Summary
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
ConstructorDescriptionChatMessageListeningEndpoint
(org.jivesoftware.smack.XMPPConnection xmppConnection) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
doStart()
Take no action by default.protected void
doStop()
Take no action by default.Subclasses may implement this method to provide component type information.protected void
onInit()
Subclasses may implement this for initialization logic.void
setHeaderMapper
(XmppHeaderMapper headerMapper) void
setPayloadExpression
(Expression payloadExpression) Specify a SpEL expression to evaluate apayload
against an incomingMessage
.void
setStanzaFilter
(org.jivesoftware.smack.filter.StanzaFilter stanzaFilter) Specify aStanzaFilter
to use for the incoming packets.Methods inherited from class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareEndpoint
getXmppConnection, isInitialized
Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
ChatMessageListeningEndpoint
public ChatMessageListeningEndpoint() -
ChatMessageListeningEndpoint
public ChatMessageListeningEndpoint(org.jivesoftware.smack.XMPPConnection xmppConnection)
-
-
Method Details
-
setHeaderMapper
-
setStanzaFilter
public void setStanzaFilter(org.jivesoftware.smack.filter.StanzaFilter stanzaFilter) Specify aStanzaFilter
to use for the incoming packets.- Parameters:
stanzaFilter
- theStanzaFilter
to use- Since:
- 4.3
- See Also:
-
XMPPConnection.addAsyncStanzaListener(StanzaListener, StanzaFilter)
-
setPayloadExpression
Specify a SpEL expression to evaluate apayload
against an incomingMessage
.- Parameters:
payloadExpression
- theExpression
for payload evaluation.- Since:
- 4.3
- See Also:
-
StanzaListener
Message
-
getComponentType
Description copied from class:IntegrationObjectSupport
Subclasses may implement this method to provide component type information.- Specified by:
getComponentType
in interfaceNamedComponent
- Overrides:
getComponentType
in classIntegrationObjectSupport
-
onInit
protected void onInit()Description copied from class:IntegrationObjectSupport
Subclasses may implement this for initialization logic.- Overrides:
onInit
in classAbstractXmppConnectionAwareEndpoint
-
doStart
protected void doStart()Description copied from class:MessageProducerSupport
Take no action by default. Subclasses may override this if they need lifecycle-managed behavior. Protected by 'lifecycleLock'.- Overrides:
doStart
in classMessageProducerSupport
-
doStop
protected void doStop()Description copied from class:MessageProducerSupport
Take no action by default. Subclasses may override this if they need lifecycle-managed behavior.- Overrides:
doStop
in classMessageProducerSupport
-