Description
Hola buenas tardes, estoy implementando reactive-commons con RabbitMQ pero no he podido iniciar una api exponiendo un evento, relaciono a continuación:
por.xml :
4.0.0
org.springframework.boot
spring-boot-starter-parent
3.1.1
com.example
demo
0.0.1-SNAPSHOT
demo
Demo project for Spring Boot
<java.version>17</java.version>
org.springframework.boot
spring-boot-starter
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.reactivecommons</groupId>
<artifactId>async-commons-rabbit-starter</artifactId>
<version>2.0.0</version>
</dependency>
<dependency>
<groupId>org.reactivecommons</groupId>
<artifactId>domain-events-api</artifactId>
<version>2.0.0</version>
</dependency>
<dependency>
<groupId>org.reactivecommons</groupId>
<artifactId>async-commons-api</artifactId>
<version>2.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
<version>RELEASE</version>
<scope>compile</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
implementación:
package com.example.demo.event_driven;
import org.reactivecommons.async.api.HandlerRegistry;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;
@configuration
@EnableMessageListeners
public class PersonListener {
public final String EVENT_PERSON_GET_INFO = "event.subscribe.person.get.info";
@Bean
public HandlerRegistry notificationEvents() {
return HandlerRegistry.register()
.serveQuery(EVENT_PERSON_GET_INFO, this::getInfoByPersonId, PersonQuery.class);
}
private Mono<PersonReply> getInfoByPersonId(PersonQuery query) {
return Mono.just(PersonReply.builder().name("Diego").address("manzana ### casa ###").build());
}
}
Error en log:
Using deprecated '-debug' fallback for parameter name resolution. Compile the affected code with '-parameters' instead or avoid its introspection: org.springframework.amqp.rabbit.core.RabbitAdmin
@dericop ya este tipo de implementación esta deprecada? como podría implementarlo? Mil gracias!