issue #275 : deprecate JmsQueueConnectionListener

j-easy · Mar 27, 2017 · 70305c5 · 70305c5
1 parent 6f07964
commit 70305c5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/easybatch-jms/src/main/java/org/easybatch/jms/JmsQueueConnectionListener.java b/easybatch-jms/src/main/java/org/easybatch/jms/JmsQueueConnectionListener.java
@@ -39,6 +39,7 @@
  *
  * @author Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)
  */
+@Deprecated
 public class JmsQueueConnectionListener implements JobListener {
 
     private static final Logger LOGGER = Logger.getLogger(JmsQueueConnectionListener.class.getSimpleName());

diff --git a/easybatch-jms/src/test/java/org/easybatch/jms/JmsIntegrationTest.java b/easybatch-jms/src/test/java/org/easybatch/jms/JmsIntegrationTest.java
@@ -88,7 +88,6 @@ public void testJmsSupport() throws Exception {
                 .reader(new JmsQueueRecordReader(queueConnectionFactory, queue))
                 .filter(new JmsPoisonRecordFilter())
                 .processor(recordCollector)
-                .jobListener(new JmsQueueConnectionListener(queueConnection))
                 .build();
 
         JobReport jobReport = new JobExecutor().execute(job);
@@ -115,7 +114,7 @@ public void testJmsSupport() throws Exception {
         assertThat(textMessage.getText()).isEqualTo(MESSAGE_TEXT);
 
         queueSession.close();
-
+        queueConnection.close();
     }
 
     @Test