Package org.chenile.mqtt.entry

Class MqttEntryPoint

java.lang.Object

org.chenile.mqtt.entry.MqttEntryPoint

public class MqttEntryPoint
extends Object

The entry point that is invoked by the Mqtt subscriber when a message arrives at a topic. This translates the message into a service invocation. The return value from the service is either published back to a reply queue (if one is specified) or just discarded if none is specified. However, errors will be logged.

Author:

Raja Shankar Kolluru

Field Summary

Fields

Modifier and Type	Field	Description
private ChenileConfiguration	chenileConfiguration
(package private) ChenileEntryPoint	chenileEntryPoint
private static final org.slf4j.Logger	logger
(package private) Map<String,String>	mqttConfig
private final ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor	Description
MqttEntryPoint()

Method Summary

Modifier and Type	Method	Description
private ChenileExchange	makeExchange(String topic)	topic will be in the format /some/stuff/serviceName/operationName extract the service name and operation name from the topic
private void	populateHeaders(org.eclipse.paho.mqttv5.common.MqttMessage message, ChenileExchange exchange)
void	process(String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)	The entry point for MQ-TT.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private static final org.slf4j.Logger logger

chenileConfiguration

@Autowired
private ChenileConfiguration chenileConfiguration

mqttConfig

@Autowired
@Qualifier("mqttConfig")
Map<String,String> mqttConfig

chenileEntryPoint

@Autowired
ChenileEntryPoint chenileEntryPoint

objectMapper

private final ObjectMapper objectMapper

Constructor Details

MqttEntryPoint

public MqttEntryPoint()

Method Details

process

public void process(String topic,
 org.eclipse.paho.mqttv5.common.MqttMessage message)
             throws Exception

The entry point for MQ-TT. It puts the message into the system and extracts the response which is logged. We support asynchronous messages at this point in time.

Parameters:

topic - the topic where the message was received

message - the message that was received

Throws:

Exception - if there is a problem in processing the message

populateHeaders

private void populateHeaders(org.eclipse.paho.mqttv5.common.MqttMessage message,
 ChenileExchange exchange)

makeExchange

private ChenileExchange makeExchange(String topic)

topic will be in the format /some/stuff/serviceName/operationName extract the service name and operation name from the topic

Parameters:

topic - the topic that received this message. Used to compute service and op name

Returns:

the exchange