2 * Copyright (c) 2015 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.netvirt.bgpmanager.oam;
10 import java.lang.management.ManagementFactory;
11 import java.util.ArrayList;
12 import java.util.concurrent.atomic.AtomicLong;
13 import javax.annotation.PostConstruct;
14 import javax.annotation.PreDestroy;
15 import javax.inject.Singleton;
16 import javax.management.AttributeChangeNotification;
17 import javax.management.JMException;
18 import javax.management.MBeanServer;
19 import javax.management.MalformedObjectNameException;
20 import javax.management.NotificationBroadcasterSupport;
21 import javax.management.ObjectName;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
26 public class BgpAlarmBroadcaster extends NotificationBroadcasterSupport
27 implements BgpAlarmBroadcasterMBean, AutoCloseable {
28 private static final Logger LOG = LoggerFactory.getLogger(BgpAlarmBroadcaster.class);
29 private final AtomicLong sequenceNumber = new AtomicLong(1);
31 private static ObjectName objectName() throws MalformedObjectNameException {
32 return new ObjectName("SDNC.FM:name=BgpAlarmObj");
37 // Set up the Infra for Posting BGP Alarms as JMX notifications.
39 MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
40 mbs.registerMBean(this, objectName());
41 } catch (JMException e) {
42 LOG.error("Adding a NotificationBroadcaster failed.", e);
44 LOG.info("{} start", getClass().getSimpleName());
51 MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
52 ObjectName objectName = objectName();
53 if (mbs.isRegistered(objectName)) {
54 mbs.unregisterMBean(objectName);
56 } catch (JMException e) {
57 LOG.error("Error unregistering MXBean", e);
62 public void sendBgpAlarmInfo(String pfx, int code, int subcode) {
63 BgpAlarmErrorCodes userAlarm = BgpAlarmErrorCodes.checkErrorSubcode(subcode);
64 ArrayList<String> arrayList = new ArrayList<>();
65 arrayList.add(userAlarm.getAlarmType());
66 arrayList.add("Peer=" + pfx);
68 sendNotification(new AttributeChangeNotification(this, sequenceNumber.incrementAndGet(),
69 System.currentTimeMillis(), "raise Alarm Object notified", "raiseAlarmObject", "ArrayList", "", arrayList));
70 LOG.info("BGP: Alarm :" + userAlarm.getAlarmType() + " has been posted.");