Simple Broadcast Service for Atmosphere.

gistfile1.java

@Service
public class BroadcastService {

	private final static Logger logger = Logger.getLogger(BroadcastService.class.getName());

	private Map<String, Broadcaster> broadcastTokens = new ConcurrentHashMap<String, Broadcaster>();

	public void broadcast(String message) {
		for (Broadcaster token : broadcastTokens.values()) {
				token.broadcast(message);
				logger.info("Broadcasting message:"+message); 
		}
	}

	public void addBroadcastToken(String channel, Broadcaster token) {
		broadcastTokens.put(channel, token);
	}

	public void destroyBroadcastToken(String channel) {
		Broadcaster token = broadcastTokens.get(channel);
		if (token != null) {
			token.destroy();
			broadcastTokens.remove(channel);
		}
	}

}