diff --git a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/publish/PublisherImpl.java b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/publish/PublisherImpl.java index df62b28e50ef387ded9edcff3af72ace3a727470..0aa05f37c5851f02b1078bcd203828b6599f57c3 100644 --- a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/publish/PublisherImpl.java +++ b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/publish/PublisherImpl.java @@ -61,8 +61,9 @@ public class PublisherImpl implements IPublisher { Message message = new Message(); RecordChangedMessages recordChangedMessages = getRecordChangedMessage(headers, indexerBatchStatus); - - message.setBody(recordChangedMessages.toString().getBytes(StandardCharsets.UTF_8)); + Gson gson = new GsonBuilder().create(); + String json = gson.toJson(recordChangedMessages); + message.setBody(json.getBytes(StandardCharsets.UTF_8)); message.setContentType("application/json"); try {