File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -132,7 +132,7 @@ void publishToStreamQueueConsumeFromStream() throws Exception {
132
132
.containsEntry ("x-routing-key" , stream );
133
133
}
134
134
135
- // @Test
135
+ @ Test
136
136
@ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
137
137
void publishAmqpValueToStreamQueueConsumeFromStream () throws Exception {
138
138
Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
@@ -170,7 +170,7 @@ void publishDataSectionsToStreamQueueConsumeFromStream() throws Exception {
170
170
assertThat (receivedBody ).isEqualTo (receivedBody );
171
171
}
172
172
173
- // @Test
173
+ @ Test
174
174
@ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
175
175
void publishSequenceSectionsToStreamQueueConsumeFromStream () throws Exception {
176
176
Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
You can’t perform that action at this time.
0 commit comments