package com.andowson.onlineuser;



import java.io.Serializable;

import java.util.Map;

import java.util.Queue;

import java.util.Set;

import java.util.concurrent.ConcurrentLinkedQueue;

import java.util.concurrent.ConcurrentMap;

import java.util.concurrent.ConcurrentHashMap;



/**

 * UserMessageQueue

 *    a singleton class

 *

 * @version 0.0.1 2004/12/22

 * @author Andowson Chang

 */

public class UserMessageQueue implements Serializable {



    private static final long serialVersionUID = 42L;

    

    private ConcurrentMap<String, ConcurrentLinkedQueue<UserMessage>> container = 

        new ConcurrentHashMap<String, ConcurrentLinkedQueue<UserMessage>>();

    

    // UserMessageQueue 衡琌