Add methods to remove queues and exchanges.

tools.descartes.prisma.core.tests/src/tools/descartes/prisma/core/TestMessageBus.java

@@ -32,4 +32,12 @@ public class TestMessageBus implements MessageBus {
 	public void publishMessage(String exchange, String routingKey, String message, Map<String, Object> headers) {
 	}
 
+	@Override
+	public void removeQueue(String queue) {
+	}
+
+	@Override
+	public void removeExchange(String exchange) {
+	}
+
 }

tools.descartes.prisma.core/src/tools/descartes/prisma/core/MessageBus.java

@@ -18,8 +18,12 @@ public interface MessageBus {
 
 	void createQueue(String queue);
 
+	void removeQueue(String queue);
+
 	void createExchange(String exchange, ExchangeType type);
 
+	void removeExchange(String exchange);
+
 	void bindQueue(String queue, String exchange, String routingKey);
 
 	void addMessageListener(String queue, final Listener listener);

tools.descartes.prisma.core/src/tools/descartes/prisma/core/impl/RabbitMQMessageBus.java

@@ -95,6 +95,15 @@ public class RabbitMQMessageBus implements MessageBus {
 		}
 	}
 
+	public void removeExchange(String exchange) {
+		try {
+			channel.exchangeDelete(exchange);
+		} catch (IOException e) {
+			log.error("Error removing exchange in RabbitMQ server", e);
+			throw new MessagingException(e);
+		}
+	}
+
 	public void createQueue(String queue) {
 		try {
 			channel.queueDeclare(queue, false, false, false, null);
@@ -104,6 +113,16 @@ public class RabbitMQMessageBus implements MessageBus {
 		}
 	}
 
+	@Override
+	public void removeQueue(String queue) {
+		try {
+			channel.queueDelete(queue);
+		} catch (IOException e) {
+			log.error("Error removing queue in RabbitMQ server", e);
+			throw new MessagingException(e);
+		}
+	}
+
 	public void bindQueue(String queue, String exchange, String routingKey) {
 		try {
 			channel.queueBind(queue, exchange, routingKey);