Adapt test to JUnit 4

[#159272967]

References #52

Author: acogoluegnes

src/test/java/com/rabbitmq/integration/tests/SelectorAppliedToTopicNotQueueIT.java

@@ -3,9 +3,9 @@
 
 import com.rabbitmq.jms.admin.RMQConnectionFactory;
 import com.rabbitmq.jms.client.message.RMQTextMessage;
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
 
 import javax.jms.DeliveryMode;
 import javax.jms.JMSException;
@@ -20,13 +20,12 @@
 import javax.jms.TopicPublisher;
 import javax.jms.TopicSession;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.Assert.assertEquals;
 
 /**
  * To make sure Session#createConsumer works for at least topic when a
  * selector is provided.
- *
+ * <p>
  * See https://github.com/rabbitmq/rabbitmq-jms-client/issues/52
  */
 public class SelectorAppliedToTopicNotQueueIT {
@@ -39,7 +38,7 @@ public class SelectorAppliedToTopicNotQueueIT {
     TopicConnection topicConn;
     QueueConnection queueConn;
 
-    @BeforeEach
+    @Before
     public void beforeTests() throws Exception {
         this.connFactory =
             (RMQConnectionFactory) AbstractTestConnectionFactory.getTestConnectionFactory()
@@ -48,7 +47,7 @@ public void beforeTests() throws Exception {
         this.queueConn = connFactory.createQueueConnection();
     }
 
-    @AfterEach
+    @After
     public void afterTests() throws Exception {
         if (this.topicConn != null)
             this.topicConn.close();
@@ -85,19 +84,19 @@ private void sendAndReceive(TopicSession topicSession, Topic topic, MessageConsu
         assertEquals(MESSAGE1, t);
     }
 
-    @Test
+    @Test(expected = UnsupportedOperationException.class)
     public void sendAndReceiveNotSupportedOnQueue() throws Exception {
         queueConn.start();
         QueueSession queueSession = queueConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
         Queue queue = queueSession.createQueue(QUEUE_NAME);
-        assertThrows(UnsupportedOperationException.class, () -> queueSession.createConsumer(queue, "boolProp"));
+        queueSession.createConsumer(queue, "boolProp");
     }
 
-    @Test
+    @Test(expected = UnsupportedOperationException.class)
     public void sendAndReceiveNotSupportedOnQueueNoLocal() throws Exception {
         queueConn.start();
         QueueSession queueSession = queueConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
         Queue queue = queueSession.createQueue(QUEUE_NAME);
-        assertThrows(UnsupportedOperationException.class, () -> queueSession.createConsumer(queue, "boolProp", false));
+        queueSession.createConsumer(queue, "boolProp", false);
     }
 }