Class PubSubEntryPoint

java.lang.Object

org.chenile.pubsub.entry.PubSubEntryPoint

public class PubSubEntryPoint
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
PubSubEntryPoint()

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(Map<String,Object> headers, ChenileExchange exchange)
void	process(String topic, String messageContent, Map<String,Object> headers)	The entry point for MQ-TT.

Methods inherited from class 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

pubSubConfig

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

chenileEntryPoint

@Autowired
private ChenileEntryPoint chenileEntryPoint

objectMapper

private final ObjectMapper objectMapper

Constructor Details

PubSubEntryPoint

public PubSubEntryPoint()

Method Details

process

public void process(String topic,
 String messageContent,
 Map<String,Object> headers)
             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

Throws:

Exception - if there is a problem in processing the message

populateHeaders

private void populateHeaders(Map<String,Object> headers,
 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