Fix possible resource leaks in MongoDB tests.
diff --git a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbAuthFailureTest.java b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbAuthFailureTest.java
index 0fb61c6..a7c4a1d 100644
--- a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbAuthFailureTest.java
+++ b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbAuthFailureTest.java
@@ -32,6 +32,7 @@
import com.mongodb.DB;
import com.mongodb.DBCollection;
+import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
/**
@@ -64,7 +65,9 @@
Assert.assertNotNull(database);
final DBCollection collection = database.getCollection("applog");
Assert.assertNotNull(collection);
- Assert.assertFalse(collection.find().hasNext());
+ try (DBCursor cursor = collection.find()) {
+ Assert.assertFalse(cursor.hasNext());
+ }
} finally {
mongoClient.close();
}
diff --git a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbCappedTest.java b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbCappedTest.java
index ffd368a..aa171c8 100644
--- a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbCappedTest.java
+++ b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbCappedTest.java
@@ -31,6 +31,7 @@
import com.mongodb.DB;
import com.mongodb.DBCollection;
+import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
@@ -61,10 +62,14 @@
Assert.assertNotNull(database);
final DBCollection collection = database.getCollection("applog");
Assert.assertNotNull(collection);
- Assert.assertTrue(collection.find().hasNext());
- final DBObject first = collection.find().next();
- Assert.assertNotNull(first);
- Assert.assertEquals(first.toMap().toString(), "Hello log", first.get("message"));
+ try (DBCursor cursor = collection.find()) {
+ Assert.assertTrue(cursor.hasNext());
+ }
+ try (DBCursor cursor = collection.find()) {
+ final DBObject first = cursor.next();
+ Assert.assertNotNull(first);
+ Assert.assertEquals(first.toMap().toString(), "Hello log", first.get("message"));
+ }
} finally {
mongoClient.close();
}
diff --git a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbMapMessageTest.java b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbMapMessageTest.java
index 99350aa..cec53d7 100644
--- a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbMapMessageTest.java
+++ b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbMapMessageTest.java
@@ -32,6 +32,7 @@
import com.mongodb.DB;
import com.mongodb.DBCollection;
+import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
@@ -55,7 +56,7 @@
@Test
public void test() {
final Logger logger = LogManager.getLogger();
- final MapMessage mapMessage = new MapMessage();
+ final MapMessage<?, Object> mapMessage = new MapMessage<>();
mapMessage.with("SomeName", "SomeValue");
mapMessage.with("SomeInt", 1);
logger.info(mapMessage);
@@ -66,11 +67,13 @@
Assert.assertNotNull(database);
final DBCollection collection = database.getCollection("applog");
Assert.assertNotNull(collection);
- final DBObject first = collection.find().next();
- Assert.assertNotNull(first);
- final String firstMapString = first.toMap().toString();
- Assert.assertEquals(firstMapString, "SomeValue", first.get("SomeName"));
- Assert.assertEquals(firstMapString, Integer.valueOf(1), first.get("SomeInt"));
+ try (DBCursor cursor = collection.find()) {
+ final DBObject first = cursor.next();
+ Assert.assertNotNull(first);
+ final String firstMapString = first.toMap().toString();
+ Assert.assertEquals(firstMapString, "SomeValue", first.get("SomeName"));
+ Assert.assertEquals(firstMapString, Integer.valueOf(1), first.get("SomeInt"));
+ }
} finally {
mongoClient.close();
}
diff --git a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbTest.java b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbTest.java
index 2a73f8c..00f39b9 100644
--- a/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbTest.java
+++ b/log4j-mongodb2/src/test/java/org/apache/logging/log4j/mongodb2/MongoDbTest.java
@@ -31,6 +31,7 @@
import com.mongodb.DB;
import com.mongodb.DBCollection;
+import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
@@ -61,9 +62,11 @@
Assert.assertNotNull(database);
final DBCollection collection = database.getCollection("applog");
Assert.assertNotNull(collection);
- final DBObject first = collection.find().next();
- Assert.assertNotNull(first);
- Assert.assertEquals(first.toMap().toString(), "Hello log", first.get("message"));
+ try (DBCursor cursor = collection.find()) {
+ final DBObject first = cursor.next();
+ Assert.assertNotNull(first);
+ Assert.assertEquals(first.toMap().toString(), "Hello log", first.get("message"));
+ }
} finally {
mongoClient.close();
}
diff --git a/log4j-mongodb3/src/test/java/org/apache/logging/log4j/mongodb3/MongoDbMapMessageTest.java b/log4j-mongodb3/src/test/java/org/apache/logging/log4j/mongodb3/MongoDbMapMessageTest.java
index 70f910e..cceb8ef 100644
--- a/log4j-mongodb3/src/test/java/org/apache/logging/log4j/mongodb3/MongoDbMapMessageTest.java
+++ b/log4j-mongodb3/src/test/java/org/apache/logging/log4j/mongodb3/MongoDbMapMessageTest.java
@@ -56,7 +56,7 @@
@Test
public void test() {
final Logger logger = LogManager.getLogger();
- final MapMessage mapMessage = new MapMessage();
+ final MapMessage<?, Object> mapMessage = new MapMessage<>();
mapMessage.with("SomeName", "SomeValue");
mapMessage.with("SomeInt", 1);
logger.info(mapMessage);
