Commit 107f95d1 authored by Yauheni Lesnikau's avatar Yauheni Lesnikau
Browse files

add label property to the message of the azure event grid message, for...

add label property to the message of the azure event grid message, for filtering messages into azure service bus subscription;
parent 9ef667c6
Pipeline #22075 failed with stages
in 22 seconds
......@@ -52,6 +52,8 @@ public class MessageBusImpl implements IMessageBus {
@Autowired
EventGridConfig eventGridConfig;
private static final String RECORD_CHANGED_MESSAGE_LABEL = "SourceService";
private static final String RECORD_CHANGED_VALUE = "StorageService";
private final static String EVENT_SUBJECT = "RecordsChanged";
private final static String EVENT_TYPE = "RecordsChanged";
private final static String EVENT_DATA_VERSION = "1.0";
......@@ -75,6 +77,7 @@ public class MessageBusImpl implements IMessageBus {
data.put(DpsHeaders.ACCOUNT_ID, headers.getPartitionIdWithFallbackToAccountId());
data.put(DpsHeaders.DATA_PARTITION_ID, headers.getPartitionIdWithFallbackToAccountId());
data.put(DpsHeaders.CORRELATION_ID, headers.getCorrelationId());
data.put(RECORD_CHANGED_MESSAGE_LABEL, RECORD_CHANGED_VALUE);
String messageId = UUID.randomUUID().toString();
eventsList.add(new EventGridEvent(
......
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