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 {
132132 .containsEntry ("x-routing-key" , stream );
133133 }
134134
135- // @Test
135+ @ Test
136136 @ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
137137 void publishAmqpValueToStreamQueueConsumeFromStream () throws Exception {
138138 Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
@@ -170,7 +170,7 @@ void publishDataSectionsToStreamQueueConsumeFromStream() throws Exception {
170170 assertThat (receivedBody ).isEqualTo (receivedBody );
171171 }
172172
173- // @Test
173+ @ Test
174174 @ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
175175 void publishSequenceSectionsToStreamQueueConsumeFromStream () throws Exception {
176176 Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
You can’t perform that action at this time.
0 commit comments