Skip to content

Commit a9a2fcc

Browse files
committed
Add @MongoDbAvailable to new test
1 parent 34db267 commit a9a2fcc

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/MongoDbMessageStoreTests.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.springframework.core.convert.converter.Converter;
2727
import org.springframework.data.convert.WritingConverter;
2828
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
29+
import org.springframework.integration.mongodb.rules.MongoDbAvailable;
2930
import org.springframework.integration.store.MessageStore;
3031
import org.springframework.messaging.support.GenericMessage;
3132

@@ -48,6 +49,7 @@ protected MessageStore getMessageStore() {
4849
}
4950

5051
@Test
52+
@MongoDbAvailable
5153
public void testCustomConverter() throws InterruptedException {
5254
MongoDbMessageStore mongoDbMessageStore =
5355
new MongoDbMessageStore(new SimpleMongoDbFactory(new MongoClient(), "test"));
@@ -78,7 +80,7 @@ public String toString() {
7880
@WritingConverter
7981
private static class FooToBytesConverter implements Converter<Foo, byte[]> {
8082

81-
private CountDownLatch called = new CountDownLatch(1);
83+
private final CountDownLatch called = new CountDownLatch(1);
8284

8385
@Override
8486
public byte[] convert(Foo source) {

0 commit comments

Comments
 (0)