sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/manager/CometSessionManager.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

package org.apache.tuscany.sca.binding.comet.runtime.manager;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

import org.atmosphere.cpr.Broadcaster;

public class CometSessionManager {

    private static final ConcurrentMap<String, Broadcaster> broadcasters = new ConcurrentHashMap<String, Broadcaster>();

    private CometSessionManager() {
    }

    public static void add(String sessionId, Broadcaster broadcaster) {
        broadcasters.put(sessionId, broadcaster);
    }

    public static Broadcaster get(String sessionId) {
        return broadcasters.get(sessionId);
    }

    public static void remove(String sessionId) {
        broadcasters.remove(sessionId);
    }

    public static void clear() {
        broadcasters.clear();
    }
}