code: private synchronized void createChannel(String channel) {
          if (!channelExists(channel)) {
              Queue queue = new Queue(channel, true, false, true);
              admin.declareQueue(queue);
              Binding binding = new Binding(channel, DestinationType.QUEUE, exchange.getName(), channel + ".#", null);
              admin.declareBinding(binding);
          }
      }
docs: Creates an event queue (thread safe) with the correct binding.
  
  @param channel Name of event handled by queue.