Commit 15174f09 authored by Abhishek Kumar (SLB)'s avatar Abhishek Kumar (SLB) Committed by Abhishek Kumar
Browse files

Constant and attribute changes

parent 0bca494e
......@@ -17,7 +17,6 @@ import org.opengroup.osdu.schema.logging.AuditLogger;
import org.opengroup.osdu.schema.provider.interfaces.messagebus.IMessageBus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
......@@ -63,17 +62,19 @@ public class MessageBusImpl implements IMessageBus {
private void publishToEventGrid(DpsHeaders headers, String schemaId, String eventType) {
List<EventGridEvent> eventsList = new ArrayList<>();
HashMap<String, Object> data = new HashMap<>();
data.put("id", schemaId);
data.put(SchemaConstants.KIND, schemaId);
data.put(DpsHeaders.ACCOUNT_ID, headers.getPartitionIdWithFallbackToAccountId());
data.put(DpsHeaders.DATA_PARTITION_ID, headers.getPartitionIdWithFallbackToAccountId());
data.put(DpsHeaders.CORRELATION_ID, headers.getCorrelationId());
String messageId = UUID.randomUUID().toString();
HashMap<String, Object> pubsubMessage = new HashMap<>();
pubsubMessage.put("data", data);
String messageId = UUID.randomUUID().toString();
//EventGridEvent supports array of messages to be triggered in a batch but at present we do not support
//schema creation in bulk so generating one event at a time.
eventsList.add(new EventGridEvent(
......@@ -113,4 +113,5 @@ public class SchemaConstants {
public final static String EVENT_SUBJECT = "schemachanged";
public final static String SCHEMA_CREATE_EVENT_TYPE = "create";
public final static String SCHEMA_UPDATE_EVENT_TYPE = "update";
public final static String KIND = "kind";
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment