skip to Main Content

Quarkus SSE Redis subscribe

I like to do an SSE with the response of redis.subscribe in quarkus. I have a sample from the quarkus-quickstart for a simple SSE @GET @Produces(MediaType.SERVER_SENT_EVENTS) @SseElementType(MediaType.TEXT_PLAIN) @Path("{name}/streaming") public Multi<String> greeting(@org.jboss.resteasy.annotations.jaxrs.PathParam String name) { return Multi.createFrom().publisher(vertx.periodicStream(2000).toMulti()) .map(l -> String.format("Hello %s!…

VIEW QUESTION

how to batch delete redis keys in one command

Now I am connect to redis, find some keys like this: > keys "user:login:user:*" user:login:user:62668 user:login:user:61970 user:login:user:63586 ...... Now I want to delete this keys, I have tried: keys "user:login:user:*" | xargs del keys "user:login:user:*" | del keys "user:login:user:*" |…

VIEW QUESTION

NOAUTH Authentication required spring-boot-data-redis+Realease Lettuce+Redis sentinel

when I restart redis cause java.util.concurrent.ExecutionException: io.lettuce.core.RedisCommandExecutionException: NOAUTH Authentication required. Why is this a problem use version like this @Configuration public class RedisConfig { @Autowired private RedisProperties redisProperties; @Bean(destroyMethod = "close") public StatefulRedisConnection<String, Object> StatefulRedisConnection() { RedisURI redisUri = RedisURI.builder().withPassword(redisProperties.getPassword())…

VIEW QUESTION
Back To Top
Search