Update

src/main/java/com/andrzejdubaj/rabbitmqdemoapp/RabbitMQConfig.java

@@ -1,6 +1,6 @@
 package com.andrzejdubaj.rabbitmqdemoapp;
 
-import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.listener.MessageListenerContainer;
@@ -18,6 +18,23 @@ Queue myQueue() {
         return new Queue(MY_QUEUE, true);
     }
 
+    @Bean
+    Exchange myExchange() {
+        return ExchangeBuilder.topicExchange("TopicExchange")
+                .durable(true)
+                .build();
+    }
+
+    @Bean
+    Binding binding() {
+        //return new Binding(MY_QUEUE, Binding.DestinationType.QUEUE, "MyTopicExchange", "topic", null);
+        return BindingBuilder
+                .bind(myQueue())
+                .to(myExchange())
+                .with("topic")
+                .noargs();
+    }
+
     @Bean
     ConnectionFactory connectionFactory() {
         CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory("localhost");