MQTemplates { public static MQTemplate singleRedisMQTemplate() { return singleRedisCustom().build(); }  static MQTemplate defaultTemplate(); static MQTemplate clusterRedisMQTemplate(); static ClusterRedisBuilder clusterRedisCustom(); static MQTemplate singleRedisMQTemplate(); static SingleRedisBuilder singleRedisCustom();  }
@Test public void testPublishWithExpired() { MQTemplate mqTemplate = MQTemplates.singleRedisMQTemplate(); long startTime = System.currentTimeMillis(); Message message = new Message(); Header header = new Header(); header.setReplyTo("ooo"); message.setHeader(header); try { mqTemplate.publish("abc", message, 10); } catch (MQException e) { System.out.println("throw exception "+ e.getClass().getName()); } long endTime = System.currentTimeMillis() - startTime; Assert.assertTrue((endTime >= 10000 && endTime < 12000)); }