2 * Copyright (c) 2015 Cisco Systems 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 ntfbenchmark.impl;
10 import com.google.common.util.concurrent.ListenableFuture;
11 import java.util.concurrent.ExecutionException;
12 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
16 public class NtfbenchNonblockingProducer extends AbstractNtfbenchProducer {
17 private static final Logger LOG = LoggerFactory.getLogger(NtfbenchNonblockingProducer.class);
19 public NtfbenchNonblockingProducer(final NotificationPublishService publishService, final int iterations,
20 final int payloadSize) {
21 super(publishService, iterations, payloadSize);
26 @SuppressWarnings("checkstyle:illegalCatch")
30 ListenableFuture<?> lastOkFuture = null;
31 for (int i = 0; i < this.iterations; i++) {
33 final ListenableFuture<?> result = this.publishService.offerNotification(this.ntf);
34 if (NotificationPublishService.REJECTED == result) {
38 lastOkFuture = result;
40 } catch (final Exception e) {
41 LOG.debug("Failed to publish notification", e);
47 this.ntfError = ntfError;
48 // We wait for last notification to be delivered to listeners.
49 if (lastOkFuture != null) {
52 } catch (InterruptedException | ExecutionException e) {
53 throw new RuntimeException(e);