/* * ============LICENSE_START========================================== * ONAP Portal SDK * =================================================================== * Copyright © 2017 AT&T Intellectual Property. All rights reserved. * =================================================================== * * Unless otherwise specified, all software contained herein is licensed * under the Apache License, Version 2.0 (the "License"); * you may not use this software 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. * * Unless otherwise specified, all documentation contained herein is licensed * under the Creative Commons License, Attribution 4.0 Intl. (the "License"); * you may not use this documentation except in compliance with the License. * You may obtain a copy of the License at * * https://creativecommons.org/licenses/by/4.0/ * * Unless required by applicable law or agreed to in writing, documentation * 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. * * ============LICENSE_END============================================ * * ECOMP is a trademark and service mark of AT&T Intellectual Property. */ package org.onap.portalsdk.core.onboarding.ueb; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; /** * A thin wrapper around ConcurrentHashMap that stores a queue for each * Requester that is waiting for a Reply. When a reply is received that has a * matching msgId, that requesters queue is populated with the reply message. * * Primarily for Portal core to track the remote applications that have placed * requests; never used by those applications. */ public class PublisherList { private final Log logger = LogFactory.getLog(getClass()); private final Map map; public PublisherList() { map = new ConcurrentHashMap<>(); } public void addPublisherToMap(String topicName, Publisher publisher) { if (this.map.containsKey(topicName)) logger.error("Publisher already exists for " + topicName); else this.map.put(topicName, publisher); } public Publisher getPublisher(String topicName) { return this.map.get(topicName); } public void removePublisherFromMap(String topicName) { this.map.remove(topicName); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("Map contains " + this.map.size() + " Publishers."); for (Map.Entry entry : this.map.entrySet()) sb.append("Entry msgId, " + entry.getKey() + " publisher" + entry.getValue()); return sb.toString(); } public int size() { return this.map.size(); } }