dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/impl/DmaapClientProvider.java

   1 /*
   2  * Copyright © 2021 Orange, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.transportpce.dmaap.client.impl;
   9
  10 import org.opendaylight.mdsal.binding.api.NotificationService;
  11 import org.opendaylight.transportpce.dmaap.client.listener.NbiNotificationsHandler;
  12 import org.opendaylight.yangtools.concepts.Registration;
  13 import org.osgi.service.component.annotations.Activate;
  14 import org.osgi.service.component.annotations.Component;
  15 import org.osgi.service.component.annotations.Reference;
  16 import org.osgi.service.metatype.annotations.AttributeDefinition;
  17 import org.osgi.service.metatype.annotations.ObjectClassDefinition;
  18 import org.slf4j.Logger;
  19 import org.slf4j.LoggerFactory;
  20
  21 @Component(configurationPid = "org.opendaylight.transportpce.dmaap")
  22 public class DmaapClientProvider {
  23
  24     @ObjectClassDefinition
  25     public @interface Configuration {
  26         @AttributeDefinition
  27         String dmaapBaseUrl() default "http://localhost:8080";
  28         @AttributeDefinition
  29         String dmaapUsername() default "";
  30         @AttributeDefinition
  31         String dmaapPassword() default "";
  32     }
  33
  34     private static final Logger LOG = LoggerFactory.getLogger(DmaapClientProvider.class);
  35     private Registration listenerRegistration;
  36
  37     @Activate
  38     public DmaapClientProvider(@Reference NotificationService notificationService, Configuration config) {
  39         this(notificationService, config.dmaapBaseUrl(), config.dmaapUsername(), config.dmaapPassword());
  40     }
  41
  42     public DmaapClientProvider(NotificationService notificationService, String baseUrl,
  43             String username, String password) {
  44         final var listener = new NbiNotificationsHandler(baseUrl, username, password);
  45         listenerRegistration = notificationService.registerCompositeListener(listener.getCompositeListener());
  46         LOG.info("DmaapClientProvider Session Initiated");
  47     }
  48
  49     /**
  50      * Method called when the blueprint container is destroyed.
  51      */
  52     public void close() {
  53         listenerRegistration.close();
  54         LOG.info("DmaapClientProvider Closed");
  55     }
  56 }