111111

src/main/java/com/hdp/customerservice/websocket/CustomerManager.java

@@ -18,20 +18,11 @@ import com.hdp.pi.wechat.messages.AbstractMessage;
 
 public class CustomerManager {
 	
-	private static LinkedBlockingQueue<AbstractMessage> queue=new LinkedBlockingQueue<AbstractMessage>();
-	
 	private static ConcurrentHashMap<String,Customer> 
 				users = new ConcurrentHashMap<String, Customer>();
 	
 	private CustomerManager(){}
 	
-	public static void pushMessage(AbstractMessage message){
-		try {
-			queue.put(message);
-		} catch (InterruptedException e) {
-		}
-	}
-	
 	public static Customer getUserByOpenId(String openId){
 		if(StringUtils.isEmpty(openId)){
 			return null;

src/main/java/com/hdp/customerservice/websocket/IMManager.java

@@ -48,9 +48,8 @@ public class IMManager {
 	}
 	
 	public static void pushMessage(AbstractMessage message){
-
+		CustomerManager.addUserIfNotExist(message);
 		try {
-			CustomerManager.pushMessage(message);
 			queue.put(message);
 		} catch (InterruptedException e) {
 		}