Package org.springframework.amqp.rabbit.listener

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

48
49
50
51
52
53
54
55
56
57
58
        // register a shutdown hook with the JVM
        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                System.out.println("Shutting down BigOperationWorker");
                listenerContainer.shutdown();
            }
        });

        // start up the listener. this will block until JVM is killed.
        listenerContainer.start();
View Full Code Here
76
77
78
79
80
81
82
83
84
85
            amqpTemplate.convertAndSend(rabbitQueue.getName(), new BigOperation("bar"));
            assertTrue(barLatch.await(5, TimeUnit.SECONDS));
            assertEquals(receievedMessageHolder.get(1).getName(), "bar");
        } finally {
            container.shutdown();
        }
    }

}
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.