182183184185186187188189190191192
template.convertAndSend("foo.end", "message"); result = getResult(consumer); assertEquals("message", result); consumer.stop(); cachingConnectionFactory.destroy(); } @Test
210211212213214215216217218219220
try { template.convertAndSend("foo", "message"); String result = getResult(consumer); assertEquals(null, result); } finally { consumer.stop(); } return null; }
231232233234235236237238239240241
try { template.convertAndSend("foo.end", "message"); String result = getResult(consumer); assertEquals("message", result); } finally { consumer.stop(); } return null; }
264265266267268269270271272273274
try { template.convertAndSend("message"); String result = getResult(consumer); assertEquals("message", result); } finally { consumer.stop(); } return null; }