fix flow test sending events

Change-Id: I7d456ad452d21ff8ff0a053058fcb253f2e37404

Author: Vali (Vasile Baluta)

src/test/java/com/ericsson/ei/flowtests/FlowTest.java

@@ -10,7 +10,6 @@
 import org.apache.commons.io.FileUtils;
 import org.apache.qpid.server.Broker;
 import org.apache.qpid.server.BrokerOptions;
-import org.apache.qpid.server.exchange.TopicExchange;
 import org.junit.After;
 import org.junit.AfterClass;
 import org.junit.Before;
@@ -19,6 +18,11 @@
 import org.junit.runner.RunWith;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@@ -160,9 +164,11 @@ public static void tearDown() throws Exception {
     @Test
     public void test() {
         try {
-            Channel channel = conn.createChannel();
             String queueName = rmqConsumer.getQueueName();
             String exchange = "ei-poc-4";
+            createExchange(exchange, queueName);
+            Channel channel = conn.createChannel();
+
 
             ArrayList<String> eventNames = getEventNamesToSend();
             int eventsCount = eventNames.size();
@@ -201,4 +207,15 @@ private ArrayList<String> getEventNamesToSend() {
 
          return eventNames;
     }
+
+    private void createExchange(final String exchangeName, final String queueName) {
+        final CachingConnectionFactory cf = new CachingConnectionFactory(AMQPBrokerManager.PORT);
+        final RabbitAdmin admin = new RabbitAdmin(cf);
+        final Queue queue = new Queue(queueName, false);
+        admin.declareQueue(queue);
+        final TopicExchange exchange = new TopicExchange(exchangeName);
+        admin.declareExchange(exchange);
+        admin.declareBinding(BindingBuilder.bind(queue).to(exchange).with("#"));
+        cf.destroy();
+    }
 }