private static final Logger LOG = LoggerFactory.getLogger(NotificationPublishServiceMock.class);
@Override
- public void putNotification(Notification notification) throws InterruptedException {
+ public void putNotification(Notification<?> notification) throws InterruptedException {
LOG.info("putNotification");
}
@Override
- public ListenableFuture<?> offerNotification(Notification notification) {
+ public ListenableFuture<?> offerNotification(Notification<?> notification) {
LOG.info("offerNotification");
throw new UnsupportedOperationException("offerNotification is not implemented");
}
@Override
- public ListenableFuture<?> offerNotification(Notification notification, int timeout, TimeUnit unit)
- throws InterruptedException {
+ public ListenableFuture<?> offerNotification(Notification<?> notification, int timeout, TimeUnit unit)
+ throws InterruptedException {
LOG.info("offerNotification");
throw new UnsupportedOperationException("offerNotification is not implemented");
}
* Send renderer notification.
* @param notification Notification
*/
- private void send(Notification notification) {
+ private void send(Notification<?> notification) {
try {
LOG.info("Sending notification {}", notification);
notificationPublishService.putNotification(notification);
private static final Logger LOG = LoggerFactory.getLogger(NotificationPublishServiceMock.class);
@Override
- public void putNotification(Notification notification) throws InterruptedException {
+ public void putNotification(Notification<?> notification) throws InterruptedException {
LOG.info("putNotification");
}
@Override
- public ListenableFuture<?> offerNotification(Notification notification) {
+ public ListenableFuture<?> offerNotification(Notification<?> notification) {
LOG.info("offerNotification");
throw new UnsupportedOperationException("offerNotification is not implemented");
}
@Override
- public ListenableFuture<?> offerNotification(Notification notification, int timeout, TimeUnit unit)
- throws InterruptedException {
+ public ListenableFuture<?> offerNotification(Notification<?> notification, int timeout, TimeUnit unit)
+ throws InterruptedException {
LOG.info("offerNotification");
throw new UnsupportedOperationException("offerNotification is not implemented");
}
LOG.info("Updated TAPI topology successfully.");
}
+ @SuppressWarnings("rawtypes")
private void sendNotification(List<Uuid> changedOneps, Mapping mapping) {
Notification notification = new NotificationBuilder()
.setNotificationType(NotificationType.ATTRIBUTEVALUECHANGE)
}
@Override
+ @SuppressWarnings("rawtypes")
public <T extends DataObject> Optional<NormalizedNode> toNormalizedNodes(@Nonnull T object,
Class dataObjectClass) {
Entry<YangInstanceIdentifier, NormalizedNode> normalizedNode =
}
@Override
+ @SuppressWarnings("rawtypes")
public <T extends Notification> ConvertType<T> notification() {
return (object, objectClass) -> {
ContainerNode normalizedNodeNotification = getCodecRegistry().toNormalizedNodeNotification(object);
<T extends DataObject> Writer writerFromRpcDataObject(@Nonnull DataObject object, Class<T> dataObjectClass,
ConvertType<T> convertType, QName rpcOutputQName, String rpcName);
- <T extends DataObject> Optional<NormalizedNode> toNormalizedNodes(@Nonnull T object,
- Class dataObjectClass);
+ @SuppressWarnings("rawtypes")
+ <T extends DataObject> Optional<NormalizedNode> toNormalizedNodes(@Nonnull T object, Class dataObjectClass);
interface ConvertType<T> {
Optional<NormalizedNode> toNormalizedNodes(T object, Class<T> clazz);
*
* @return {@link ConvertType} converter for {@link Notification}
*/
+ @SuppressWarnings("rawtypes")
<T extends Notification> ConvertType<T> notification();
}
xmlStreamWriter.writeStartElement(XMLConstants.DEFAULT_NS_PREFIX,
rpcOutputQName.getLocalName(), rpcOutputQName.getNamespace().toString());
xmlStreamWriter.writeDefaultNamespace(rpcOutputQName.getNamespace().toString());
- NormalizedNode rpcOutputNormalizedNode = convertType.toNormalizedNodes(dataObjectClass.cast(object),
- dataObjectClass).get();
+ NormalizedNode rpcOutputNormalizedNode =
+ convertType.toNormalizedNodes(dataObjectClass.cast(object), dataObjectClass).get();
for (final NormalizedNode child : ((ContainerNode)rpcOutputNormalizedNode).body()) {
normalizedNodeWriter.write(child);
}