@@ -0,0 +1,836 @@
+package com.wizzardo.http.websocket;%0A%0Aimport com.wizzardo.http.framework.di.Injectable;%0A%0Aimport java.util.Collections;%0Aimport java.util.Set;%0Aimport java.util.concurrent.ConcurrentHashMap;%0A%0A/**%0A * Created by wizzardo on 08.12.15.%0A */%0A@Injectable%0Apublic class DefaultWebSocketHandler extends WebSocketHandler %7B%0A    protected Set%3CWebSocketListener%3E listeners = Collections.newSetFromMap(new ConcurrentHashMap%3C%3E());%0A%0A    @Override%0A    public void onConnect(WebSocketListener listener) %7B%0A        listeners.add(listener);%0A    %7D%0A%0A    @Override%0A    public void onDisconnect(WebSocketListener listener) %7B%0A        listeners.remove(listener);%0A    %7D%0A%0A    public void broadcast(String s) %7B%0A        Message message = new Message(s);%0A        for (WebSocketListener listener : listeners) %7B%0A            listener.sendMessage(message);%0A        %7D%0A    %7D%0A%0A%7D%0A

add DefaultWebSocketHandler