File tree Expand file tree Collapse file tree
rqueue-core/src/main/java/com/github/sonus21/rqueue/listener
rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -279,7 +279,9 @@ private void invokeHandler(Object payload) throws Exception {
279279 // Spring's HandlerMethod can hold a bean *name* (String) until createWithResolvedBean()
280280 // looks it up in the BeanFactory. method.invoke needs the actual instance.
281281 org .springframework .messaging .handler .HandlerMethod resolved =
282- handlerMethod .getBean () instanceof String ? handlerMethod .createWithResolvedBean () : handlerMethod ;
282+ handlerMethod .getBean () instanceof String
283+ ? handlerMethod .createWithResolvedBean ()
284+ : handlerMethod ;
283285 Method method = resolved .getMethod ();
284286 Object bean = resolved .getBean ();
285287 if (!method .canAccess (bean )) {
Original file line number Diff line number Diff line change 6969class NatsBackendEndToEndIT {
7070
7171 @ Container
72- static final GenericContainer <?> NATS =
73- new GenericContainer <>( DockerImageName .parse ("nats:2.10-alpine" ))
74- .withCommand ("-js" )
75- .withExposedPorts (4222 )
76- .waitingFor (Wait .forLogMessage (".*Server is ready.*\\ n" , 1 ));
72+ static final GenericContainer <?> NATS = new GenericContainer <>(
73+ DockerImageName .parse ("nats:2.10-alpine" ))
74+ .withCommand ("-js" )
75+ .withExposedPorts (4222 )
76+ .waitingFor (Wait .forLogMessage (".*Server is ready.*\\ n" , 1 ));
7777
7878 @ DynamicPropertySource
7979 static void registerProps (DynamicPropertyRegistry r ) {
@@ -82,8 +82,11 @@ static void registerProps(DynamicPropertyRegistry r) {
8282 () -> "nats://" + NATS .getHost () + ":" + NATS .getMappedPort (4222 ));
8383 }
8484
85- @ Autowired RqueueMessageEnqueuer enqueuer ;
86- @ Autowired TestListener listener ;
85+ @ Autowired
86+ RqueueMessageEnqueuer enqueuer ;
87+
88+ @ Autowired
89+ TestListener listener ;
8790
8891 @ Test
8992 void enqueueIsReceivedByListener () throws Exception {
You can’t perform that action at this time.
0 commit comments