File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change 55
55
import org .assertj .core .api .InstanceOfAssertFactories ;
56
56
import org .assertj .core .api .InstanceOfAssertFactory ;
57
57
import org .assertj .core .api .ObjectAssert ;
58
- import org .junit .Ignore ;
59
58
import org .junit .jupiter .api .AfterEach ;
60
59
import org .junit .jupiter .api .BeforeEach ;
61
60
import org .junit .jupiter .api .Test ;
@@ -133,9 +132,8 @@ void publishToStreamQueueConsumeFromStream() throws Exception {
133
132
.containsEntry ("x-routing-key" , stream );
134
133
}
135
134
136
- @ Test
135
+ // @Test
137
136
@ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
138
- @ Ignore
139
137
void publishAmqpValueToStreamQueueConsumeFromStream () throws Exception {
140
138
Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
141
139
AMQPMessage message = new AMQPMessage ();
@@ -172,9 +170,8 @@ void publishDataSectionsToStreamQueueConsumeFromStream() throws Exception {
172
170
assertThat (receivedBody ).isEqualTo (receivedBody );
173
171
}
174
172
175
- @ Test
173
+ // @Test
176
174
@ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11_9 )
177
- @ Ignore
178
175
void publishSequenceSectionsToStreamQueueConsumeFromStream () throws Exception {
179
176
Producer p = session .createProducer ("/amq/queue/" + stream , QoS .AT_LEAST_ONCE );
180
177
AMQPMessage message = new AMQPMessage ();
You can’t perform that action at this time.
0 commit comments