GatewayFilters

@RefreshScope
@Component
public class AuthenticationFilter implements GatewayFilter {

    final Logger LOGGER = LoggerFactory.getLogger(AuthenticationFilter.class);

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();

// Make your business logic, this is a simple sample.


        if (!request.getHeaders().containsKey("x-api-key")) {
            return this.onError(exchange,"api-key missing",HttpStatus.FORBIDDEN);
        }

        return chain.filter(exchange); // Forward to route
    }

    private Mono<Void> onError(ServerWebExchange exchange, String err, HttpStatus httpStatus)  {
        ServerHttpResponse response = exchange.getResponse();
        response.setStatusCode(httpStatus);
        return response.setComplete();
    }

Source: stackoverflow.com

Similar codes

0 vote364 views1 answer
Caused by: java.lang.IllegalStateException: stream has already been operated upon or closed
Java
0 vote373 views1 answer
Check if combobox has specified value
Java
0 vote370 views1 answer
Print queue in java
Java
0 vote342 views1 answer
How can i convert an int to string java
Java
41 votes365 views3 answers
Java loop hashmap
Java
-1 vote375 views1 answer
192.168.223.12:8080
Java
0 vote336 views1 answer
Java truncate bigdecimal
Java
4 votes354 views1 answer
Find difference in days between two dates java
Java
0 vote344 views1 answer
Stream reduce stringbuilder
Java
4 votes359 views2 answers
Integer.MAX_VALUE
Java