public abstract class AbstractMqttMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler
implements org.springframework.context.SmartLifecycle
| Constructor and Description |
|---|
AbstractMqttMessageHandler(java.lang.String url,
java.lang.String clientId) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
connectIfNeeded() |
protected abstract void |
doStart() |
protected abstract void |
doStop() |
protected java.lang.String |
getClientId() |
java.lang.String |
getComponentType() |
int |
getPhase() |
protected java.lang.String |
getUrl() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected void |
onInit() |
protected abstract void |
publish(java.lang.String topic,
java.lang.Object mqttMessage) |
void |
setAutoStartup(boolean autoStartup) |
void |
setConverter(MqttMessageConverter converter) |
void |
setDefaultQos(int defaultQos) |
void |
setDefaultRetained(boolean defaultRetain) |
void |
setDefaultTopic(java.lang.String defaultTopic) |
void |
setPhase(int phase) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
getOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic AbstractMqttMessageHandler(java.lang.String url,
java.lang.String clientId)
public void setDefaultTopic(java.lang.String defaultTopic)
public void setDefaultQos(int defaultQos)
public void setDefaultRetained(boolean defaultRetain)
public void setConverter(MqttMessageConverter converter)
protected java.lang.String getUrl()
protected java.lang.String getClientId()
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.AbstractMessageHandlerprotected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.context.IntegrationObjectSupportjava.lang.Exceptionpublic final void start()
start in interface org.springframework.context.Lifecycleprotected abstract void doStart()
public final void stop()
stop in interface org.springframework.context.Lifecycleprotected abstract void doStop()
public boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic void setPhase(int phase)
public void setAutoStartup(boolean autoStartup)
public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecycleprotected void handleMessageInternal(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exceptionprotected abstract void connectIfNeeded()
protected abstract void publish(java.lang.String topic,
java.lang.Object mqttMessage)
throws java.lang.Exception
java.lang.Exception