sample

sample_test.java

@Test
public void testReceive1() throws Exception {
    receiver.addMessageListener("NotificationQueue");
    sender.sendMessage("NotificationQueue", "bir mesaj gönderiliyor...queue.ya", null);

    System.out.println("First style message send...");

    TimeUnit.SECONDS.sleep(10);

    //receiver.getLatch().await(10000, TimeUnit.MILLISECONDS);
    //assertThat(receiver.getLatch().getCount()).isEqualTo(0);
}