diff --git a/redisinsight/ui/src/slices/browser/stream.ts b/redisinsight/ui/src/slices/browser/stream.ts index a169dd4c8a..fe739c0540 100644 --- a/redisinsight/ui/src/slices/browser/stream.ts +++ b/redisinsight/ui/src/slices/browser/stream.ts @@ -963,6 +963,7 @@ export function claimPendingMessages( if (isStatusSuccessful(status)) { dispatch(claimConsumerMessagesSuccess()) dispatch(fetchConsumers()) + dispatch(fetchConsumerGroups()) if (data.affected.length) { dispatch(deleteMessageFromList(data.affected[0])) dispatch(addMessageNotification( @@ -1014,6 +1015,7 @@ export function ackPendingEntriesAction( dispatch(ackPendingEntriesSuccess()) dispatch(deleteMessageFromList(entries[0])) dispatch(fetchConsumers()) + dispatch(fetchConsumerGroups()) dispatch(addMessageNotification( successMessages.MESSAGE_ACTION(entries[0], 'acknowledged') )) diff --git a/redisinsight/ui/src/slices/tests/browser/stream.spec.ts b/redisinsight/ui/src/slices/tests/browser/stream.spec.ts index 5087fbad3a..9cf969d89a 100644 --- a/redisinsight/ui/src/slices/tests/browser/stream.spec.ts +++ b/redisinsight/ui/src/slices/tests/browser/stream.spec.ts @@ -1416,6 +1416,7 @@ describe('stream slice', () => { ackPendingEntriesSuccess(), deleteMessageFromList('0-1'), loadConsumerGroups(), + loadConsumerGroups(), addMessageNotification( successMessages.MESSAGE_ACTION( entries.join(''), @@ -1482,6 +1483,7 @@ describe('stream slice', () => { claimConsumerMessages(), claimConsumerMessagesSuccess(), loadConsumerGroups(), + loadConsumerGroups(), deleteMessageFromList('0-1'), addMessageNotification( successMessages.MESSAGE_ACTION('0-1', 'claimed') @@ -1517,6 +1519,7 @@ describe('stream slice', () => { claimConsumerMessages(), claimConsumerMessagesSuccess(), loadConsumerGroups(), + loadConsumerGroups(), addMessageNotification( successMessages.NO_CLAIMED_MESSAGES() )