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, Florian Schmaus
-
Field Summary
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLockFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionChatMessageListeningEndpoint(org.jivesoftware.smack.XMPPConnection xmppConnection) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoStart()Take no action by default.protected voiddoStop()Take no action by default.Subclasses may implement this method to provide component type information.protected voidonInit()Subclasses may implement this for initialization logic.voidsetHeaderMapper(XmppHeaderMapper headerMapper) voidsetPayloadExpression(Expression payloadExpression) Specify a SpEL expression to evaluate apayloadagainst an incomingMessage.voidsetStanzaFilter(org.jivesoftware.smack.filter.StanzaFilter stanzaFilter) Specify aStanzaFilterto use for the incoming packets.Methods inherited from class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareEndpoint
getXmppConnection, isInitializedMethods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods 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 aStanzaFilterto use for the incoming packets.- Parameters:
stanzaFilter- theStanzaFilterto use- Since:
- 4.3
- See Also:
-
XMPPConnection.addAsyncStanzaListener(StanzaListener, StanzaFilter)
-
setPayloadExpression
Specify a SpEL expression to evaluate apayloadagainst an incomingMessage.- Parameters:
payloadExpression- theExpressionfor payload evaluation.- Since:
- 4.3
- See Also:
-
StanzaListenerMessage
-
getComponentType
Description copied from class:IntegrationObjectSupportSubclasses may implement this method to provide component type information.- Specified by:
getComponentTypein interfaceNamedComponent- Overrides:
getComponentTypein classIntegrationObjectSupport
-
onInit
protected void onInit()Description copied from class:IntegrationObjectSupportSubclasses may implement this for initialization logic.- Overrides:
onInitin classAbstractXmppConnectionAwareEndpoint
-
doStart
protected void doStart()Description copied from class:MessageProducerSupportTake no action by default. Subclasses may override this if they need lifecycle-managed behavior. Protected by 'lifecycleLock'.- Overrides:
doStartin classMessageProducerSupport
-
doStop
protected void doStop()Description copied from class:MessageProducerSupportTake no action by default. Subclasses may override this if they need lifecycle-managed behavior.- Overrides:
doStopin classMessageProducerSupport
-