import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.aaa.web.servlet.ServletSupport;
import org.opendaylight.restconf.api.query.PrettyPrintParam;
+import org.opendaylight.restconf.nb.rfc8040.ErrorTagMapping;
import org.opendaylight.restconf.server.spi.RestconfStream;
import org.osgi.service.component.annotations.Activate;
import org.osgi.service.component.annotations.Component;
private static final String PROP_STREAMS_CONFIGURATION = ".streamsConfiguration";
private static final String PROP_RESTCONF = ".restconf";
private static final String PROP_PRETTY_PRINT = ".prettyPrint";
+ private static final String PROP_ERROR_TAG_MAPPING = ".errorTagMapping";
private final @NonNull String restconf;
+ private final @NonNull ErrorTagMapping errorTagMapping;
private final @NonNull PrettyPrintParam prettyPrint;
private final RestconfStream.Registry streamRegistry;
private final ServletSupport servletSupport;
public DefaultRestconfStreamServletFactory(final ServletSupport servletSupport, final String restconf,
final RestconfStream.Registry streamRegistry, final StreamsConfiguration streamsConfiguration,
- final PrettyPrintParam prettyPrint, final String namePrefix, final int corePoolSize,
- final boolean useWebsockets) {
+ final ErrorTagMapping errorTagMapping, final PrettyPrintParam prettyPrint, final String namePrefix,
+ final int corePoolSize, final boolean useWebsockets) {
this.servletSupport = requireNonNull(servletSupport);
this.restconf = requireNonNull(restconf);
if (restconf.endsWith("/")) {
}
this.streamRegistry = requireNonNull(streamRegistry);
this.streamsConfiguration = requireNonNull(streamsConfiguration);
+ this.errorTagMapping = requireNonNull(errorTagMapping);
this.prettyPrint = requireNonNull(prettyPrint);
pingExecutor = new DefaultPingExecutor(namePrefix, corePoolSize);
this.useWebsockets = useWebsockets;
this(servletSupport, (String) props.get(PROP_RESTCONF),
(RestconfStream.Registry) props.get(PROP_STREAM_REGISTRY),
(StreamsConfiguration) props.get(PROP_STREAMS_CONFIGURATION),
+ (ErrorTagMapping) props.get(PROP_ERROR_TAG_MAPPING),
(PrettyPrintParam) props.get(PROP_PRETTY_PRINT),
(String) props.get(PROP_NAME_PREFIX), (int) requireNonNull(props.get(PROP_CORE_POOL_SIZE)),
(boolean) requireNonNull(props.get(PROP_USE_WEBSOCKETS)));
return prettyPrint;
}
+ @Override
+ public ErrorTagMapping errorTagMapping() {
+ return errorTagMapping;
+ }
+
@Override
@Deactivate
public void close() {
}
public static Map<String, ?> props(final String restconf, final RestconfStream.Registry streamRegistry,
- final PrettyPrintParam prettyPrint, final boolean useSSE, final StreamsConfiguration streamsConfiguration,
- final String namePrefix, final int corePoolSize) {
+ final ErrorTagMapping errorTagMapping, final PrettyPrintParam prettyPrint, final boolean useSSE,
+ final StreamsConfiguration streamsConfiguration, final String namePrefix, final int corePoolSize) {
return Map.of(
PROP_RESTCONF, restconf,
PROP_STREAM_REGISTRY, streamRegistry,
+ PROP_ERROR_TAG_MAPPING, errorTagMapping,
PROP_PRETTY_PRINT, prettyPrint,
PROP_USE_WEBSOCKETS, !useSSE,
PROP_STREAMS_CONFIGURATION, streamsConfiguration,