File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change 25
25
import com .rabbitmq .stream .EnvironmentBuilder ;
26
26
import com .rabbitmq .stream .OffsetSpecification ;
27
27
import com .rabbitmq .stream .Producer ;
28
+ import com .rabbitmq .stream .impl .TestUtils .BrokerVersion ;
29
+ import com .rabbitmq .stream .impl .TestUtils .BrokerVersionAtLeast ;
28
30
import io .netty .channel .EventLoopGroup ;
29
31
import java .nio .charset .StandardCharsets ;
30
32
import java .util .HashSet ;
@@ -168,6 +170,7 @@ void allMessagesSentWithRoutingKeyRoutingShouldBeThenConsumed() throws Exception
168
170
}
169
171
170
172
@ Test
173
+ @ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11 )
171
174
void allMessagesForSameUserShouldEndUpInSamePartition () throws Exception {
172
175
int messageCount = 10_000 * partitions ;
173
176
int userCount = 10 ;
You can’t perform that action at this time.
0 commit comments