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() |
java.lang.String |
getClientId() |
int |
getClientInstance()
Incremented each time the client is connected.
|
java.lang.String |
getComponentType() |
protected org.springframework.messaging.converter.MessageConverter |
getConverter() |
int |
getPhase() |
protected java.lang.String |
getUrl() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
incrementClientInstance() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected void |
onInit() |
protected abstract void |
publish(java.lang.String topic,
java.lang.Object mqttMessage,
org.springframework.messaging.Message<?> message) |
void |
setAutoStartup(boolean autoStartup) |
void |
setConverter(org.springframework.messaging.converter.MessageConverter 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, setShouldTrack
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public 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(org.springframework.messaging.converter.MessageConverter converter)
protected org.springframework.messaging.converter.MessageConverter getConverter()
protected java.lang.String getUrl()
public java.lang.String getClientId()
public int getClientInstance()
public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.handler.AbstractMessageHandler
protected void incrementClientInstance()
protected void onInit() throws java.lang.Exception
onInit
in class org.springframework.integration.context.IntegrationObjectSupport
java.lang.Exception
public final void start()
start
in interface org.springframework.context.Lifecycle
protected abstract void doStart()
public final void stop()
stop
in interface org.springframework.context.Lifecycle
protected abstract void doStop()
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public int getPhase()
getPhase
in interface org.springframework.context.Phased
public void setPhase(int phase)
public void setAutoStartup(boolean autoStartup)
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class org.springframework.integration.handler.AbstractMessageHandler
java.lang.Exception
protected abstract void connectIfNeeded()
protected abstract void publish(java.lang.String topic, java.lang.Object mqttMessage, org.springframework.messaging.Message<?> message) throws java.lang.Exception
java.lang.Exception