Add @MongoDbAvailable to new test

This commit is contained in:
Gary Russell
2019-05-30 10:51:30 -04:00
parent 34db267a8a
commit a9a2fccf1f

View File

@@ -26,6 +26,7 @@ import org.junit.Test;
import org.springframework.core.convert.converter.Converter;
import org.springframework.data.convert.WritingConverter;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.integration.mongodb.rules.MongoDbAvailable;
import org.springframework.integration.store.MessageStore;
import org.springframework.messaging.support.GenericMessage;
@@ -48,6 +49,7 @@ public class MongoDbMessageStoreTests extends AbstractMongoDbMessageStoreTests {
}
@Test
@MongoDbAvailable
public void testCustomConverter() throws InterruptedException {
MongoDbMessageStore mongoDbMessageStore =
new MongoDbMessageStore(new SimpleMongoDbFactory(new MongoClient(), "test"));
@@ -78,7 +80,7 @@ public class MongoDbMessageStoreTests extends AbstractMongoDbMessageStoreTests {
@WritingConverter
private static class FooToBytesConverter implements Converter<Foo, byte[]> {
private CountDownLatch called = new CountDownLatch(1);
private final CountDownLatch called = new CountDownLatch(1);
@Override
public byte[] convert(Foo source) {