yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-07 21:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Defined a constant instead of duplicating string literal #1982 (#5819)

Browse Source
This commit is contained in:
truemanD 2022-07-01 19:53:59 +03:00 committed by GitHub
parent 8007024721
commit 1808b1a056
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
catalog-rest-service/src/main/java/org/openmetadata/catalog/CatalogApplication.java
View File

@ -275,6 +275,7 @@ public class CatalogApplication extends Application<CatalogApplicationConfig> {
private void intializeWebsockets(CatalogApplicationConfig catalogConfig, Environment environment) {
SocketAddressFilter socketAddressFilter;
String pathSpec = "/api/v1/push/feed/*";
if (catalogConfig.getAuthorizerConfiguration() != null) {
socketAddressFilter =
new SocketAddressFilter(
@ -289,14 +290,14 @@ public class CatalogApplication extends Application<CatalogApplicationConfig> {
environment.getApplicationContext().setContextPath("/");
environment
.getApplicationContext()
.addFilter(new FilterHolder(socketAddressFilter), "/api/v1/push/feed/*", EnumSet.of(DispatcherType.REQUEST));
environment.getApplicationContext().addServlet(new ServletHolder(new FeedServlet()), "/api/v1/push/feed/*");
.addFilter(new FilterHolder(socketAddressFilter), pathSpec, EnumSet.of(DispatcherType.REQUEST));
environment.getApplicationContext().addServlet(new ServletHolder(new FeedServlet()), pathSpec);
// Upgrade connection to websocket from Http
try {
WebSocketUpgradeFilter webSocketUpgradeFilter =
WebSocketUpgradeFilter.configureContext(environment.getApplicationContext());
webSocketUpgradeFilter.addMapping(
new ServletPathSpec("/api/v1/push/feed/*"),
new ServletPathSpec(pathSpec),
(servletUpgradeRequest, servletUpgradeResponse) ->
new JettyWebSocketHandler(WebSocketManager.getInstance().getEngineIoServer()));
} catch (ServletException ex) {