Skip to content

Commit 026370a

Browse files
authored
Fix bug of converting system properties from EventData to Spring message in Eventhub binder (Azure#22683)
* fix bug of converting system properties * add changelog
1 parent c8119b7 commit 026370a

File tree

6 files changed

+10
-2
lines changed

6 files changed

+10
-2
lines changed

sdk/spring/azure-spring-cloud-autoconfigure/CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
# Release History
22

33
## 2.7.0-beta.1 (Unreleased)
4+
### Key Bug Fixes
5+
- Fixed `EventHubMessageConverter` to load all system properties of `EventData` and put in the header of org.springframework.messaging.Message.([#22683](https://github.com/Azure/azure-sdk-for-java/pull/22683/))
46

57

68
## 2.6.0 (2021-06-23)

sdk/spring/azure-spring-cloud-starter-eventhubs/CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
# Release History
22

33
## 2.7.0-beta.1 (Unreleased)
4+
### Key Bug Fixes
5+
- Fixed `EventHubMessageConverter` to load all system properties of `EventData` and put in the header of org.springframework.messaging.Message.([#22683](https://github.com/Azure/azure-sdk-for-java/pull/22683/))
46

57

68
## 2.6.0 (2021-06-23)

sdk/spring/azure-spring-cloud-stream-binder-eventhubs/CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
# Release History
22

33
## 2.7.0-beta.1 (Unreleased)
4+
### Key Bug Fixes
5+
- Fixed `EventHubMessageConverter` to load all system properties of `EventData` and put in the header of org.springframework.messaging.Message.([#22683](https://github.com/Azure/azure-sdk-for-java/pull/22683/))
46

57

68
## 2.6.0 (2021-06-23)

sdk/spring/azure-spring-cloud-test-eventhubs/src/test/java/com/azure/spring/test/eventhubs/stream/binder/EventHubBinderSyncModeIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public Supplier<Flux<Message<String>>> supply(Sinks.Many<Message<String>> many)
6666
public Consumer<Message<String>> consume() {
6767
return message -> {
6868
LOGGER.info("EventHubBinderRecordModeIT: New message received: '{}'", message.getPayload());
69-
if (message.getPayload().equals(EventHubBinderSyncModeIT.message)) {
69+
if (message.getPayload().equals(EventHubBinderSyncModeIT.message) && message.getHeaders().containsKey("x-opt-enqueued-time")) {
7070
latch.countDown();
7171
}
7272
};

sdk/spring/azure-spring-integration-eventhubs/CHANGELOG.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
# Release History
22

33
## 2.7.0-beta.1 (Unreleased)
4-
4+
### Key Bug Fixes
5+
- Fixed `EventHubMessageConverter` to load all system properties of `EventData` and put in the header of org.springframework.messaging.Message.([#22683](https://github.com/Azure/azure-sdk-for-java/pull/22683/))
56

67
## 2.6.0 (2021-06-23)
78
### New Features

sdk/spring/azure-spring-integration-eventhubs/src/main/java/com/azure/spring/integration/eventhub/converter/EventHubMessageConverter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,7 @@ protected Map<String, Object> buildCustomHeaders(EventData azureMessage) {
8686

8787
private Map<String, Object> getSystemProperties(EventData azureMessage) {
8888
Map<String, Object> result = new HashMap<>();
89+
result.putAll(azureMessage.getSystemProperties());
8990
result.put(EventHubHeaders.ENQUEUED_TIME, azureMessage.getEnqueuedTime());
9091
result.put(EventHubHeaders.OFFSET, azureMessage.getOffset());
9192
result.put(EventHubHeaders.SEQUENCE_NUMBER, azureMessage.getSequenceNumber());

0 commit comments

Comments
 (0)