/******************************************************************************* * Copyright 2016-2017 ZTE, Inc. and others. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. ******************************************************************************/ package org.onap.msb.apiroute.wrapper.queue; import java.util.HashSet; import java.util.Set; import java.util.concurrent.atomic.AtomicReference; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class ServiceListCache { private static final Logger LOGGER = LoggerFactory.getLogger(ServiceListCache.class); private final static AtomicReference> serviceNameList4Cache = new AtomicReference>(new HashSet()); public static Set getLatestServiceNamelist() { return serviceNameList4Cache.get(); } public static void setLatestServiceNamelist(Set newServicenamelist){ serviceNameList4Cache.set(newServicenamelist); LOGGER.info("------current total Watch Service Num :"+ newServicenamelist.size()); } public synchronized static void removeService(String serviceName){ Set servicenamelist=serviceNameList4Cache.get(); servicenamelist.remove(serviceName); serviceNameList4Cache.set(servicenamelist); LOGGER.info("------current total Watch Service Num :"+ servicenamelist.size()); } }