AtmosphereResource getting removed from resources list permanently while using Transport.SSE. about atmosphere HOT 3 CLOSED

            	 String authErrorMsg  = "401 response received, but no WWW-Authenticate header was present";
            	
            	 if(t.getMessage().contains(authErrorMsg) && needAuth){
            		 // Means auth error from server on reconnecting.
            	 }
                connected = Boolean.FALSE;
                attachedToServerInfo.setConnected(false);
                logger.error("Connection refused by Atmosphere Server exception is " + t);
            }
        }).on(Event.CLOSE.name(), new Function<String>() {
            @Override
            public void on(String t) {
            	logger.trace("Connection closed");
            }
        }).on(Event.OPEN.name(), new Function<String>() {
            @Override
            public void on(String t) {
            	connected = Boolean.TRUE;
                final LinkedHashMap<ReportKey, Object> map = new LinkedHashMap<>();
                map.put(ReportKey.URL, uri);
                map.put(ReportKey.DATE_TIME, System.currentTimeMillis());
                map.put(ReportKey.CLIENT_ID, clientUuid);
                logger.trace("Connection opened");
                infoMessage.setVisible(false);
                if (flag) {
					flag = Boolean.FALSE;
					attachedToServerInfo.setConnected(false);
				}
				if (!attachedToServerInfo.isConnected()) {
					attachedToServerInfo.setConnected(true);
					infoMessage.setIsDispose(true);
				}
            }
         }).open(**getRequestBuilder**(uri, this.serverToken).build());

@Override
public void handle(AtmosphereFramework framework, Class<Object> annotatedClass) {
    try {
        Class<?> aClass = annotatedClass;
        SBManagedService a = aClass.getAnnotation(SBManagedService.class);
        framework.setBroadcasterCacheClassName(a.broadcasterCache().getName());

        List<AtmosphereInterceptor> l = new LinkedList<AtmosphereInterceptor>();
        AnnotationUtil.defaultManagedServiceInterceptors(framework, l);

        atmosphereConfig(a.atmosphereConfig(), framework);
        filters(a.broadcastFilters(), framework);

        AtmosphereInterceptor aa = listeners(a.listeners(), framework);
        if (aa != null) {
            l.add(aa);
        }

        Object c = framework.newClassInstance(Object.class, aClass);
        AtmosphereHandler handler = framework.newClassInstance(ManagedAtmosphereHandler.class,
                        ManagedAtmosphereHandler.class).configure(framework.getAtmosphereConfig(), c);

        framework.filterManipulator(new BroadcasterConfig.FilterManipulator() {
            @Override
            public Object unwrap(Object o) {
                if (o != null && ManagedAtmosphereHandler.Managed.class.isAssignableFrom(o.getClass())) {
                    o = ManagedAtmosphereHandler.Managed.class.cast(o).object();
                }
                return o;
            }

            @Override
            public BroadcastFilter.BroadcastAction wrap(BroadcastFilter.BroadcastAction a, boolean wasWrapped) {
                if (wasWrapped) {
                    return new BroadcastFilter.BroadcastAction(a.action(), new ManagedAtmosphereHandler.Managed(a.message()));
                } else {
                    return a;
                }
            }
        });

        AnnotationUtil.interceptorsForManagedService(framework, Arrays.asList(a.interceptors()), l);
        framework.addAtmosphereHandler(a.path(), handler, broadcaster(framework, a.broadcaster(), a.path()), l);
    } catch (Throwable e) {
        logger.warn("", e);
    }
}