2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018 Huawei Technologies Co., Ltd. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.onap.ccsdk.sli.plugins.restconfdiscovery;
23 import org.glassfish.jersey.media.sse.InboundEvent;
24 import org.glassfish.jersey.media.sse.EventListener;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
29 * Listener that can be registered to listen for notifications.
31 class EventHandler implements EventListener {
32 private static final Logger log = LoggerFactory.getLogger(EventListener.class);
33 private RestconfDiscoveryNode node;
35 public EventHandler(RestconfDiscoveryNode node) {
40 public void onEvent(InboundEvent event) {
41 String payload = event.readData();
42 if (!node.eventQueue().offer(payload)) {
43 log.error("Unable to process event {} as processing queue is full", payload);