src/main/java/io/paradoxical/rabbitmq/ChannelInitializer.java
/**
     * Initializes a topics endpoint. If the exchange doesn't have a queue name creates an adhoc queue
     * otherwise binds the topic to the supplied queue  and binds each routing key for the queue.
     * <p/>
     * If no routing key is specified, the routing key is the queue name
     *
     * @return
     * @throws IOException
     */
Initializes a topics endpoint. If the exchange doesn't have a queue name creates an adhoc queue
otherwise binds the topic to the supplied queue  and binds each routing key for the queue.

If no routing key is specified, the routing key is the queue name


Initializes a topics endpoint . If the exchange doesn ' t have a queue name creates an adhoc queue otherwise binds the topic to the supplied queue and binds each routing key for the queue . If no routing key is specified the routing key is the queue name
public static Queue bindQueueToRoutingKeys(final Channel channel, String queueName, final Exchange exchange, final Optional<List<String>> optionalRoutes)
            throws IOException {
        final List<String> routingKeys = optionalRoutes.orElse(Arrays.asList(exchange.getExchangeName()));
        for (String routingKey : routingKeys) {
            channel.queueBind(
                    queueName,
                    exchange.getExchangeName(),
                    routingKey);
        }
        return new Queue(queueName, optionalRoutes);
    }
public static Queue bindQueueToRoutingKeys ( final Channel channel , String queueName , final Exchange exchange , final Optional < List < String > > optionalRoutes ) throws IOException { final List < String > routingKeys = optionalRoutes . orElse ( Arrays . asList ( exchange . getExchangeName ( ) ) ) ; for ( String routingKey : routingKeys ) { channel . queueBind ( queueName , exchange . getExchangeName ( ) , routingKey ) ; } return new Queue ( queueName , optionalRoutes ) ; }
Initializes a topics endpoint.
Initializes a topics endpoint .