public class BindingDOMNotificationPublishServiceAdapter extends Object implements NotificationPublishService, AutoCloseable
Modifier and Type | Class and Description |
---|---|
protected static class |
BindingDOMNotificationPublishServiceAdapter.Builder |
REJECTED
Constructor and Description |
---|
BindingDOMNotificationPublishServiceAdapter(BindingToNormalizedNodeCodec codec,
DOMNotificationPublishService domPublishService) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
BindingToNormalizedNodeCodec |
getCodecRegistry() |
DOMNotificationPublishService |
getDomPublishService() |
com.google.common.util.concurrent.ListenableFuture<?> |
offerNotification(org.opendaylight.yangtools.yang.binding.Notification notification)
Publishes a notification to subscribed listeners.
|
com.google.common.util.concurrent.ListenableFuture<?> |
offerNotification(org.opendaylight.yangtools.yang.binding.Notification notification,
int timeout,
TimeUnit unit)
Publishes a notification to subscribed listeners.
|
void |
putNotification(org.opendaylight.yangtools.yang.binding.Notification notification)
Publishes a notification to subscribed listeners.
|
public BindingDOMNotificationPublishServiceAdapter(BindingToNormalizedNodeCodec codec, DOMNotificationPublishService domPublishService)
public BindingToNormalizedNodeCodec getCodecRegistry()
public DOMNotificationPublishService getDomPublishService()
public void putNotification(org.opendaylight.yangtools.yang.binding.Notification notification) throws InterruptedException
NotificationPublishService
putNotification
in interface NotificationPublishService
notification
- the notification to publish.InterruptedException
- if interrupted while waitingpublic com.google.common.util.concurrent.ListenableFuture<?> offerNotification(org.opendaylight.yangtools.yang.binding.Notification notification)
NotificationPublishService
Still guaranteed not to block. Returns Listenable Future which will complete once.
offerNotification
in interface NotificationPublishService
notification
- the notification to publish.NotificationPublishService.REJECTED
if resource
constraints preventpublic com.google.common.util.concurrent.ListenableFuture<?> offerNotification(org.opendaylight.yangtools.yang.binding.Notification notification, int timeout, TimeUnit unit) throws InterruptedException
NotificationPublishService
offerNotification
in interface NotificationPublishService
notification
- the notification to publish.timeout
- how long to wait before giving up, in units of unitunit
- a TimeUnit determining how to interpret the
timeout parameterNotificationPublishService.REJECTED
if resource
constraints preventInterruptedException
- if interrupted while waitingpublic void close()
close
in interface AutoCloseable
Copyright © 2019 OpenDaylight. All rights reserved.