public abstract class AbstractMqttMessageHandler extends AbstractMessageHandler implements SmartLifecycle
loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| 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()
Subclasses may implement this method to provide component type information.
|
int |
getPhase() |
protected java.lang.String |
getUrl() |
protected void |
handleMessageInternal(Message<?> message) |
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic 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()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class AbstractMessageHandlerprotected void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportjava.lang.Exception - Any exception.protected abstract void doStart()
protected abstract void doStop()
public void setPhase(int phase)
public void setAutoStartup(boolean autoStartup)
public boolean isAutoStartup()
isAutoStartup in interface SmartLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface SmartLifecycleprotected void handleMessageInternal(Message<?> message) throws java.lang.Exception
handleMessageInternal in class 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