Adapt test to Java 6

References #400
rabbitmq · Aug 27, 2018 · 6a5d962 · 6a5d962
1 parent ffd6b7d
commit 6a5d962
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/test/java/com/rabbitmq/client/test/ConnectionFactoryTest.java b/src/test/java/com/rabbitmq/client/test/ConnectionFactoryTest.java
@@ -101,8 +101,8 @@ protected AMQConnection createConnection(ConnectionParams params, FrameHandler f
     }
 
     @Test public void shouldUseDnsResolutionWhenOneAddressAndNoTls() throws Exception {
-        AMQConnection connection = mock(AMQConnection.class);
-        AtomicReference<AddressResolver> addressResolver = new AtomicReference<>();
+        final AMQConnection connection = mock(AMQConnection.class);
+        final AtomicReference<AddressResolver> addressResolver = new AtomicReference<AddressResolver>();
 
         ConnectionFactory connectionFactory = new ConnectionFactory() {
             @Override
@@ -125,8 +125,8 @@ protected AddressResolver createAddressResolver(List<Address> addresses) {
     }
 
     @Test public void shouldNotUseDnsResolutionWhenOneAddressAndNoTls() throws Exception {
-        AMQConnection connection = mock(AMQConnection.class);
-        AtomicReference<AddressResolver> addressResolver = new AtomicReference<>();
+        final AMQConnection connection = mock(AMQConnection.class);
+        final AtomicReference<AddressResolver> addressResolver = new AtomicReference<AddressResolver>();
 
         ConnectionFactory connectionFactory = new ConnectionFactory() {
             @Override