Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-08 19:15:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #1934

Browse Source
This commit is contained in:
Clebert Suconic 2018-03-06 12:39:43 -05:00
commit 315c1e4c55
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
View File

@ -17,6 +17,7 @@
package org.apache.activemq.artemis.core.server.impl; package org.apache.activemq.artemis.core.server.impl;
import org.apache.activemq.artemis.api.core.ActiveMQException; import org.apache.activemq.artemis.api.core.ActiveMQException;
import org.apache.activemq.artemis.api.core.ActiveMQNonExistentQueueException;
import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.ActiveMQServerLogger; import org.apache.activemq.artemis.core.server.ActiveMQServerLogger;
@ -40,6 +41,8 @@ public class TransientQueueManagerImpl extends ReferenceCounterUtil implements T
try { try {
server.destroyQueue(queueName, null, false); server.destroyQueue(queueName, null, false);
} catch (ActiveMQNonExistentQueueException e) {
// ignore
} catch (ActiveMQException e) { } catch (ActiveMQException e) {
ActiveMQServerLogger.LOGGER.errorOnDeletingQueue(queueName.toString(), e); ActiveMQServerLogger.LOGGER.errorOnDeletingQueue(queueName.toString(), e);
} }

5
examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java
View File

@ -34,12 +34,12 @@ import org.apache.activemq.artemis.api.core.ActiveMQObjectClosedException;
* *
* - sends messages to a queue "slow.consumer.kill". * - sends messages to a queue "slow.consumer.kill".
* - starts a consumer BUT does not consume any messages. * - starts a consumer BUT does not consume any messages.
* - waits for 8 seconds and tries to consume a message. * - waits for 10 seconds and tries to consume a message.
* - receive an exception as the connection should already be closed. * - receive an exception as the connection should already be closed.
*/ */
public class KillSlowConsumerExample { public class KillSlowConsumerExample {
public static final int WAIT_TIME = 7; public static final int WAIT_TIME = 10;
public static void main(final String[] args) throws Exception { public static void main(final String[] args) throws Exception {
@ -98,7 +98,6 @@ public class KillSlowConsumerExample {
} }
} }
} }
} }
} }

2
examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java
View File

@ -103,8 +103,6 @@ public class NotifySlowConsumerExample {
if (!isNotified) { if (!isNotified) {
throw new RuntimeException("SlowConsumerExample.demoSlowConsumerNotify() FAILED; timeout occurred before" + " - slow consumer notification was received. "); throw new RuntimeException("SlowConsumerExample.demoSlowConsumerNotify() FAILED; timeout occurred before" + " - slow consumer notification was received. ");
} }
} }
} }
} }

4
examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml
View File

@ -52,13 +52,13 @@ under the License.
<address-setting match="slow.consumer.kill"> <address-setting match="slow.consumer.kill">
<slow-consumer-threshold>10</slow-consumer-threshold> <slow-consumer-threshold>10</slow-consumer-threshold>
<slow-consumer-policy>KILL</slow-consumer-policy> <slow-consumer-policy>KILL</slow-consumer-policy>
<slow-consumer-check-period>5</slow-consumer-check-period> <slow-consumer-check-period>3</slow-consumer-check-period>
</address-setting> </address-setting>
<address-setting match="slow.consumer.notify"> <address-setting match="slow.consumer.notify">
<slow-consumer-threshold>10</slow-consumer-threshold> <slow-consumer-threshold>10</slow-consumer-threshold>
<slow-consumer-policy>NOTIFY</slow-consumer-policy> <slow-consumer-policy>NOTIFY</slow-consumer-policy>
<slow-consumer-check-period>5</slow-consumer-check-period> <slow-consumer-check-period>3</slow-consumer-check-period>
</address-setting> </address-setting>
</address-settings> </address-settings>