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

-2 votes215 views1 answer
Void vs return
Java
1 vote238 views1 answer
Spring scheduled
Java Spring
2 votes202 views3 answers
String array to arraylist android
Java
4 votes206 views1 answer
Java get excectuon time
Java
6 votes231 views1 answer
Best IDE for java
Java
1 vote182 views1 answer
Combinations
Java
-2 votes181 views1 answer
How to implements interface in java
Java
3 votes226 views3 answers
Isblank vs isempty
Java
0 vote212 views1 answer
Can abstract method be protected, default, private
Java
0 vote226 views1 answer
Java lambda expression in priorityqueue
Java