public abstract class AbstractMqttMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
| Constructor and Description |
|---|
AbstractMqttMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
java.lang.String... topic) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
getClientId() |
java.lang.String |
getComponentType() |
protected MqttMessageConverter |
getConverter() |
protected java.lang.String[] |
getTopic() |
protected java.lang.String |
getUrl() |
protected void |
onInit() |
void |
setConverter(MqttMessageConverter converter) |
doStart, doStop, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toStringpublic AbstractMqttMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
java.lang.String... topic)
public void setConverter(MqttMessageConverter converter)
protected java.lang.String getUrl()
protected java.lang.String getClientId()
protected MqttMessageConverter getConverter()
protected java.lang.String[] getTopic()
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupportprotected void onInit()
onInit in class org.springframework.integration.endpoint.MessageProducerSupport