Package org.springframework.amqp.rabbit.listener

Examples of org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.stop()

84
85
86
87
88
89
90
91
92
93
94
    template.convertAndSend("retry.test.exchange", "retry.test.binding", "Hello, world!");
    template.convertAndSend("retry.test.exchange", "retry.test.binding", "Hello, world!");
    assertTrue(latch.await(10, TimeUnit.SECONDS));
    Thread.sleep(2000);
    assertEquals(0, ((Map) new DirectFieldAccessor(cache).getPropertyValue("map")).size());
    container.stop();
    ctx.close();
  }

  @SuppressWarnings("rawtypes")
  @Test
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    template.send("retry.test.exchange", "retry.test.binding", message);
    template.send("retry.test.exchange", "retry.test.binding", message);
    assertTrue(latch.await(10, TimeUnit.SECONDS));
    Thread.sleep(2000);
    assertEquals(0, ((Map) new DirectFieldAccessor(cache).getPropertyValue("map")).size());
    container.stop();
    ctx.close();
  }

  public class POJO {
    public void handleMessage(String foo) {
View Full Code Here
182
183
184
185
186
187
188
189
190
191
    container.setQueueNames("qux");
    Mockito.verify(connectionFactory1, never()).createConnection();
    Mockito.verify(connectionFactory2, never()).createConnection();
    Mockito.verify(defaultConnectionFactory).createConnection();

    container.stop();
  }


}
View Full Code Here
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
    } while (receiveCount.get() < count * 2);


    executor.shutdown();
    assertTrue(executor.awaitTermination(10, TimeUnit.SECONDS));
    container.stop();

    assertEquals(count * 2, results.size());

    for (Map.Entry<Double, Object> entry : results.entrySet()) {
      assertEquals(entry.getKey() * 3, entry.getValue());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.