Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- rabbitTemplate.convertAndSend(exchangeNameOut, message.getString(PERSISTENCE_MESSAGE_ROUTING_KEY),
- message.getString(PERSISTENCE_MESSAGE_BODY), new CorrelationData(""+analyticRuntime.getId()));
- @RabbitListener(queues = "${rabbit.queue.mail.name}",containerFactory = "rabbitListenerContainerFactory")
- public void processMailMessage(Message message) {
- log.info("ENTER [processMailMessage] ");
- Mail mail;
- JSONObject messageBody = new JSONObject(new String(message.getBody()));
- String asset = "" + messageBody.get(Constants.PERSISTENCE_MESSAGE_ASSET_ID_KEY);
- String body = "" + messageBody.get(Constants.PERSISTENCE_MESSAGE_EVENT_KEY);
- String alarms = "";
- log.info("[processMailMessage] message.getMessageProperties().getCorrelationId() : " + message.getMessageProperties().getCorrelationId()";
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement