Update MessageParser.java

FreddieAkeroyd · web-flow · commit e617cfd183a2 · 2020-07-21T19:19:18.000+01:00
Set running false before closing consumer
diff --git a/base/uk.ac.stfc.isis.ibex.activemq/src/uk/ac/stfc/isis/ibex/activemq/message/MessageParser.java b/base/uk.ac.stfc.isis.ibex.activemq/src/uk/ac/stfc/isis/ibex/activemq/message/MessageParser.java
@@ -80,6 +80,7 @@ public void setActiveMQConsumer(MessageConsumer consumer) {
      *             Thrown if close fails.
      */
     public void closeJMSConsumer() throws JMSException {
+        setRunning(false);
         jmsConsumer.close();
         
         /**
@@ -95,7 +96,6 @@ public void closeJMSConsumer() throws JMSException {
          * 
          */
         jmsConsumer = null;
-        setRunning(false);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -80,6 +80,7 @@ public void setActiveMQConsumer(MessageConsumer consumer) {`
`80`	`80`	`* Thrown if close fails.`
`81`	`81`	`*/`
`82`	`82`	`public void closeJMSConsumer() throws JMSException {`
	`83`	`+ setRunning(false);`
`83`	`84`	`jmsConsumer.close();`
`84`	`85`
`85`	`86`	`/**`
`@@ -95,7 +96,6 @@ public void closeJMSConsumer() throws JMSException {`
`95`	`96`	`*`
`96`	`97`	`*/`
`97`	`98`	`jmsConsumer = null;`
`98`		`- setRunning(false);`
`99`	`99`	`}`
`100`	`100`
`101`	`101`	`/**`