public abstract class AbstractMqttMessageHandler extends AbstractMessageHandler implements org.springframework.context.Lifecycle
EXPRESSION_PARSER, logger
Constructor and Description |
---|
AbstractMqttMessageHandler(java.lang.String url,
java.lang.String clientId) |
Modifier and Type | Method and Description |
---|---|
protected void |
connectIfNeeded()
Deprecated.
subclasses should check the connection in
publish(String, Object, Message) . |
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()
Subclasses may implement this method to provide component type information.
|
protected org.springframework.messaging.converter.MessageConverter |
getConverter() |
protected java.lang.String |
getUrl() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
incrementClientInstance() |
boolean |
isRunning() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
protected abstract void |
publish(java.lang.String topic,
java.lang.Object mqttMessage,
org.springframework.messaging.Message<?> message) |
void |
setConverter(org.springframework.messaging.converter.MessageConverter converter) |
void |
setDefaultQos(int defaultQos) |
void |
setDefaultRetained(boolean defaultRetain) |
void |
setDefaultTopic(java.lang.String defaultTopic) |
void |
start() |
void |
stop() |
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
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()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected void incrementClientInstance()
protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractMessageHandler
java.lang.Exception
- Any 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
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class AbstractMessageHandler
java.lang.Exception
@Deprecated protected void connectIfNeeded()
publish(String, Object, Message)
.publish(String, Object, Message)
.protected abstract void publish(java.lang.String topic, java.lang.Object mqttMessage, org.springframework.messaging.Message<?> message) throws java.lang.Exception
java.lang.Exception