rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/Routing.java
@Test
  @Ignore("Need to implement topic exchange first")
  public void doubleBinding() throws IOException {
    channel.queueBind(Q1, "amq.topic", "x.#");
    channel.queueBind(Q1, "amq.topic", "#.x");
    channel.basicPublish("amq.topic", "x.y", null, "x.y".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
    channel.basicPublish("amq.topic", "y.x", null, "y.x".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
    channel.basicPublish("amq.topic", "x.x", null, "x.x".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
  }
/**
   * If a queue has more than one binding to an exchange, it should NOT receive duplicate copies of
   * a message that matches both bindings.
   */
If a queue has more than one binding to an exchange, it should NOT receive duplicate copies of
a message that matches both bindings.
If a queue has more than one binding to an exchange it should NOT receive duplicate copies of a message that matches both bindings .
@Test
  @Ignore("Need to implement topic exchange first")
  public void doubleBinding() throws IOException {
    channel.queueBind(Q1, "amq.topic", "x.#");
    channel.queueBind(Q1, "amq.topic", "#.x");
    channel.basicPublish("amq.topic", "x.y", null, "x.y".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
    channel.basicPublish("amq.topic", "y.x", null, "y.x".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
    channel.basicPublish("amq.topic", "x.x", null, "x.x".getBytes());
    checkGet(Q1, true);
    checkGet(Q1, false);
  }
@ Test @ Ignore ( "Need to implement topic exchange first" ) public void doubleBinding ( ) throws IOException { channel . queueBind ( Q1 , "amq.topic" , "x.#" ) ; channel . queueBind ( Q1 , "amq.topic" , "#.x" ) ; channel . basicPublish ( "amq.topic" , "x.y" , null , "x.y" . getBytes ( ) ) ; checkGet ( Q1 , true ) ; checkGet ( Q1 , false ) ; channel . basicPublish ( "amq.topic" , "y.x" , null , "y.x" . getBytes ( ) ) ; checkGet ( Q1 , true ) ; checkGet ( Q1 , false ) ; channel . basicPublish ( "amq.topic" , "x.x" , null , "x.x" . getBytes ( ) ) ; checkGet ( Q1 , true ) ; checkGet ( Q1 , false ) ; }
If a queue has more than one binding to an exchange, it should NOT receive duplicate copies of
 a message that matches both bindings.
If a queue has more than one binding to an exchange it should NOT receive duplicate copies of a message that matches both bindings .