KMUS commented on issue #2632:
URL: https://github.com/apache/camel-quarkus/issues/2632#issuecomment-845808690
I am sorry, sure.
Some errors are gone, some still remains. Hope this is enough to reproduce
it.
```
@TopCommand
@Command(name = "cli", mixinStandardHelpOptions = true, version = "cli 0.1")
public class Main implements QuarkusApplication, Runnable {
@Inject
CamelRunner starter;
@Override
public void run() {
starter.run();
}
@Override
public int run(String... args) throws Exception {
return new CommandLine(this).execute(args);
}
public static void main(String[] args) {
Quarkus.run(Main.class, args);
}
}
@Dependent
public class CamelRunner {
@Inject // or producer is null
@Produce("direct:runner")
ProducerTemplate producer;
public void run() {
try {
producer.sendBody("test");
Quarkus.waitForExit();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
@ApplicationScoped
public class CamelRoutes extends RouteBuilder {
@Override
public void configure() {
from("direct:runner")
.log("${body}");
from("timer://foo-timer?fixedRate=true&period=5000")
.setBody(constant("foo-test"))
.to("reactive-streams:foo-notification1");
from("reactive-streams:foo-notification2")
.to("direct:foo-notification2");
from("direct:foo-notification2")
.to("direct:foo-notification3"); // does not call Bar#onBar
// from("direct:foo-notification2")
// .bean(Bar.class, "onBar"); // works fine
}
}
public class Bar {
@Consume("direct:foo-notification3")
public void onBar(String str) {
System.out.println("Bar#onBar: " + str);
}
}
@ApplicationScoped
public class Foo {
@Inject
CamelContext context;
Subscriber<String> subscriber;
@PostConstruct
public void init() {
subscriber = CamelReactiveStreams.get(context)
.streamSubscriber("foo-notification2", String.class);
}
@Incoming("foo-mutiny-notification")
public void consume(String notify) {
subscriber.onNext(notify);
}
@Outgoing("foo-mutiny-notification")
public Publisher<String> consume() {
var camel = CamelReactiveStreams.get(context);
return camel.fromStream("foo-notification1", String.class);
}
}
```
```
application.properties
quarkus.banner.enabled=false
quarkus.package.main-class=foo.bar.Main
pom.xml
<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
https://maven.apache.org/xsd/maven-4.0.0.xsd";
xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";>
<modelVersion>4.0.0</modelVersion>
<groupId>foo.bar</groupId>
<artifactId>command-mode</artifactId>
<version>1.0.0-SNAPSHOT</version>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-universe-bom</artifactId>
<version>1.13.4.Final</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-picocli</artifactId>
</dependency>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-smallrye-reactive-messaging</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-direct</artifactId>
<version>1.9.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-bean</artifactId>
<version>1.9.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-timer</artifactId>
<version>1.9.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-reactive-streams</artifactId>
<version>1.9.0-SNAPSHOT</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-maven-plugin</artifactId>
<version>1.13.4.Final</version>
<extensions>true</extensions>
<executions>
<execution>
<goals>
<goal>build</goal>
<goal>generate-code</goal>
<goal>generate-code-tests</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
</plugin>
</plugins>
</build>
<properties>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
</project>
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
