class 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);
	}

}