Spring Integration MQTT Adapter

org.springframework.integration.mqtt.inbound
Class AbstractMqttMessageDrivenChannelAdapter

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.endpoint.MessageProducerSupport
              extended by org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent
Direct Known Subclasses:
MqttPahoMessageDrivenChannelAdapter

public abstract class AbstractMqttMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport

Abstract class for MQTT Message-Driven Channel Adapters.

Since:
1.0
Author:
Gary Russell

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
AbstractMqttMessageDrivenChannelAdapter(java.lang.String url, java.lang.String clientId, java.lang.String... topic)
           
 
Method Summary
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)
           
 
Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
doStart, doStop, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
 
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.springframework.integration.support.context.NamedComponent
getComponentName
 

Constructor Detail

AbstractMqttMessageDrivenChannelAdapter

public AbstractMqttMessageDrivenChannelAdapter(java.lang.String url,
                                               java.lang.String clientId,
                                               java.lang.String... topic)
Method Detail

setConverter

public void setConverter(MqttMessageConverter converter)

getUrl

protected java.lang.String getUrl()

getClientId

protected java.lang.String getClientId()

getConverter

protected MqttMessageConverter getConverter()

getTopic

protected java.lang.String[] getTopic()

onInit

protected void onInit()
Overrides:
onInit in class org.springframework.integration.endpoint.MessageProducerSupport

getComponentType

public java.lang.String getComponentType()
Specified by:
getComponentType in interface org.springframework.integration.support.context.NamedComponent
Overrides:
getComponentType in class org.springframework.integration.context.IntegrationObjectSupport

Spring Integration MQTT Adapter