package com.qxueyou.scc.sys.msg;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class CustomerMsgProducerService implements ICustomerMsgProducerService{
	
	@Autowired
	KafkaTemplate<String,String>  template;
	
	public static String VIDEO_LIVE_TOPIC ="test.topic";

	@Override
	public void doSendMediaVideoLiveMsg() {
		
		for(int i=0;;){
			i++;
			template.setDefaultTopic(VIDEO_LIVE_TOPIC);
		    template.sendDefault(String.valueOf(i), "foo"+i);
		    try {
				Thread.sleep(10*1000);
				 template.flush();
			} catch (InterruptedException e) {
				
			}
		   
		}
		
//	    template.flush();
//	    container.stop();
		
	}
	
	
	
	
}