@SpringBootApplication
@EnableScheduling
public class Application {

	public static void main(String[] args) {
		SpringApplication.run(Application.class, args);

	}
}

@Test
public void sendMessageToQueue() {
		
	queueTemplate.convertAndSend(queue, "hello world");
}
@Test
public void receiveMessageFromQueue() {

	queueTemplate.receiveAndConvert(queue);
}

@Test
public void sendMessageToQueueWithSelector() {
		
	queueTemplate.convertAndSend(queue, "hello world",
			(MessagePostProcessor)(message)-> {
		{
			message.setStringProperty("name", "tony");
			return message;
		}
	});
}
@Test
public void receiveMessageFromQueueWithSelector() {

	queueTemplate.receiveSelected(queue, "name='tony'");
}

@Test
public void publishMessageToTopic() {
	
	topicTemplate.convertAndSend(topic, "hello world");
}