Skip to content
Snippets Groups Projects
Commit 91d880c8 authored by Alan Braz's avatar Alan Braz
Browse files

send message to indexer queue

parent c8c03eda
No related branches found
No related tags found
1 merge request!6Trusted ibm
......@@ -32,6 +32,7 @@ import org.opengroup.osdu.core.ibm.messagebus.IMessageFactory;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.springframework.stereotype.Component;
import org.springframework.web.context.annotation.RequestScope;
import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
......@@ -47,6 +48,7 @@ public class PublisherImpl implements IPublisher {
@Inject
private JaxRsDpsLog logger;
@Override
public void publishStatusChangedTagsToTopic(DpsHeaders headers, JobStatus indexerBatchStatus) throws Exception {
......@@ -64,7 +66,7 @@ public class PublisherImpl implements IPublisher {
try {
logger.info("Indexer publishes message " + headers.getCorrelationId());
rabbitMQ.sendMessage(message.toString());
rabbitMQ.sendMessage("indexer", message.toString());
}
catch (Exception e) {
logger.error(e.getMessage(), e);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment