Scaling reactive APIs - www.razorcodes.com

code9_RedisPuller4.java

@RestController
public class CustomerController {
    private final RedisPuller redisPuller;

    @GetMapping(value="/customer/{customerId}",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<CustomerUpdatedEvent> getCustomerData(@PathVariable String customerId) {
        return redisPuller.getStreamEvents(customerId, Instant.now().toEpochMilli());
    }
}