@@ -14,13 +14,6 @@ const common = new Common();
14
14
15
15
let keyName = common . generateWord ( 20 ) ;
16
16
let consumerGroupName = common . generateWord ( 20 ) ;
17
- const cliCommands = [
18
- `XGROUP CREATE ${ keyName } ${ consumerGroupName } $ MKSTREAM` ,
19
- `XADD ${ keyName } * message apple` ,
20
- `XADD ${ keyName } * message orange` ,
21
- `XREADGROUP GROUP ${ consumerGroupName } Alice COUNT 1 STREAMS ${ keyName } >` ,
22
- `XREADGROUP GROUP ${ consumerGroupName } Bob COUNT 1 STREAMS ${ keyName } >`
23
- ] ;
24
17
25
18
fixture `Pending messages`
26
19
. meta ( { type : 'regression' , rte : rte . standalone } )
@@ -65,6 +58,13 @@ test('Verify that user can\'t select currently selected Consumer to Claim messag
65
58
test ( 'Verify that the message is claimed only if its idle time is greater than the Min Idle Time' , async t => {
66
59
keyName = common . generateWord ( 20 ) ;
67
60
consumerGroupName = common . generateWord ( 20 ) ;
61
+ const cliCommands = [
62
+ `XGROUP CREATE ${ keyName } ${ consumerGroupName } $ MKSTREAM` ,
63
+ `XADD ${ keyName } * message apple` ,
64
+ `XADD ${ keyName } * message orange` ,
65
+ `XREADGROUP GROUP ${ consumerGroupName } Alice COUNT 1 STREAMS ${ keyName } >` ,
66
+ `XREADGROUP GROUP ${ consumerGroupName } Bob COUNT 1 STREAMS ${ keyName } >`
67
+ ] ;
68
68
69
69
// Add New Stream Key with pending message
70
70
for ( const command of cliCommands ) {
@@ -83,6 +83,13 @@ test('Verify that the message is claimed only if its idle time is greater than t
83
83
test ( 'Verify that when user toggle optional parameters on, he can see optional fields' , async t => {
84
84
keyName = common . generateWord ( 20 ) ;
85
85
consumerGroupName = common . generateWord ( 20 ) ;
86
+ const cliCommands = [
87
+ `XGROUP CREATE ${ keyName } ${ consumerGroupName } $ MKSTREAM` ,
88
+ `XADD ${ keyName } * message apple` ,
89
+ `XADD ${ keyName } * message orange` ,
90
+ `XREADGROUP GROUP ${ consumerGroupName } Alice COUNT 1 STREAMS ${ keyName } >` ,
91
+ `XREADGROUP GROUP ${ consumerGroupName } Bob COUNT 1 STREAMS ${ keyName } >`
92
+ ] ;
86
93
87
94
// Add New Stream Key with pending message
88
95
for ( const command of cliCommands ) {
0 commit comments