this.path = requireNonNull(path);
this.streamName = requireNonNull(streamName);
checkArgument(!streamName.isEmpty());
- this.formatter = getFormatterFactory().getFormatter();
+ formatter = getFormatterFactory().getFormatter();
LOG.debug("output type: {}, {}", outputType, this.outputType);
}
}
@Override
- public void setQueryParams(final Instant start, final Instant stop, final String filter,
+ public void setQueryParams(final Instant startTime, final Instant stopTime, final String filter,
final boolean leafNodesOnly, final boolean skipNotificationData) {
- super.setQueryParams(start, stop, filter, leafNodesOnly, skipNotificationData);
+ setQueryParams(startTime, stopTime, leafNodesOnly, skipNotificationData);
try {
- this.formatter = getFormatter(filter);
+ formatter = getFormatter(filter);
} catch (XPathExpressionException e) {
throw new IllegalArgumentException("Failed to get filter", e);
}
*/
@Override
public String getOutputType() {
- return this.outputType.getName();
+ return outputType.getName();
}
@Override
*/
@Override
public String getStreamName() {
- return this.streamName;
+ return streamName;
}
/**
* @return The configured schema path that points to observing YANG notification schema node.
*/
public Absolute getSchemaPath() {
- return this.path;
+ return path;
}
public final synchronized void listen(final DOMNotificationService notificationService) {