Commit 4e76674d authored by Guillaume Surrel's avatar Guillaume Surrel
Browse files

Clear Naming directory on stop.

parent 5ce168db
......@@ -204,6 +204,7 @@ public class AMQPService {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "AMQPService.stopService()");
amqpService.stop();
Naming.clearAll();
}
/**
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2009 ScalAgent Distributed Technologies
* Copyright (C) 2009 - 2011 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -243,6 +243,12 @@ public class Naming {
return proxies.values();
}
public static void clearAll() {
exchanges.clear();
queues.clear();
proxies.clear();
}
public static void createDefaults() throws Exception {
IExchange exchange;
exchange = new DirectExchange(IExchange.DEFAULT_EXCHANGE_NAME, true);
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment