You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: src/reference/antora/modules/ROOT/pages/message-store.adoc
+9Lines changed: 9 additions & 0 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -158,3 +158,12 @@ It also allows the end marker to arrive at the aggregator before all the other r
158
158
159
159
In addition, for configuration convenience, a `GroupConditionProvider` contract has been introduced.
160
160
The `AbstractCorrelatingMessageHandler` checks if the provided `ReleaseStrategy` implements this interface and extracts a `conditionSupplier` for group condition evaluation logic.
161
+
162
+
[[use-lock-registry]]
163
+
== Use LockRegistry
164
+
165
+
Starting with version 6.5, the `MessageStore` abstraction operate the metadata of message group with lock.
166
+
This lock acquires the groupId and generated by `LockRegister`.
167
+
Its purpose is to operate on the atomicity of messages and message groups.
168
+
In multiple threads, adding or removing messages or updating metadata at the same time, some implementations may have message group errors if the lock is missing.
169
+
By default, `LockRegister` uses `DefaultLockRegistry`, and developers can set it to the implementation they need through `setLockRegistry`
0 commit comments