ReceiveService { public void sendMessage(final Object data) { Runnable worker = new Runnable() { @Override public void run() { while (!ReceiveContant.run.get()) { try { Thread.sleep(1000 * 10); } catch (InterruptedException e) { logger.error(e.getMessage(), e); } } String queueName = getQueueName(); messageService.sendObject(queueName, data); ReceiveContant.RECE_COUNT.incrementAndGet(); } }; reciveExecutor.execute(worker); }  void sendMessage(final Object data); void sendMessageToMQ(final Map<String, Object> map);  }
@Test public void testSendMessage() { fail("Not yet implemented"); }