File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -1480,7 +1480,8 @@ function abstractPersistence (opts) {
1480
1480
1481
1481
testInstance ( 'stream all will messages' , ( t , instance ) => {
1482
1482
const client = {
1483
- id : '12345'
1483
+ id : '12345' ,
1484
+ brokerId : instance . broker . id
1484
1485
}
1485
1486
const toWrite = {
1486
1487
topic : 'hello/died' ,
@@ -1512,10 +1513,12 @@ function abstractPersistence (opts) {
1512
1513
testInstance ( 'stream all will message for unknown brokers' , ( t , instance ) => {
1513
1514
const originalId = instance . broker . id
1514
1515
const client = {
1515
- id : '42'
1516
+ id : '42' ,
1517
+ brokerId : instance . broker . id
1516
1518
}
1517
1519
const anotherClient = {
1518
- id : '24'
1520
+ id : '24' ,
1521
+ brokerId : instance . broker . id
1519
1522
}
1520
1523
const toWrite1 = {
1521
1524
topic : 'hello/died42' ,
You can’t perform that action at this time.
0 commit comments