Getting Started with Quarkus

Prerequisites

1. Create the Project

<properties>
 <quarkus.version>3.31.3</quarkus.version>
 <maven.compiler.release>21</maven.compiler.release>
</properties>
<dependencyManagement>
 <dependencies>
 <dependency>
 <groupId>io.quarkus</groupId>
 <artifactId>quarkus-bom</artifactId>
 <version>${quarkus.version}</version>
 <type>pom</type>
 <scope>import</scope>
 </dependency>
 </dependencies>
</dependencyManagement>
<dependencies>
 <dependency>
 <groupId>org.atmosphere</groupId>
 <artifactId>atmosphere-quarkus-extension</artifactId>
 <version>4.0.0</version>
 </dependency>
 <dependency>
 <groupId>io.quarkus</groupId>
 <artifactId>quarkus-undertow</artifactId>
 </dependency>
 <dependency>
 <groupId>io.quarkus</groupId>
 <artifactId>quarkus-websockets</artifactId>
 </dependency>
 <dependency>
 <groupId>io.quarkus</groupId>
 <artifactId>quarkus-jackson</artifactId>
 </dependency>
</dependencies>
<build>
 <plugins>
 <plugin>
 <groupId>io.quarkus</groupId>
 <artifactId>quarkus-maven-plugin</artifactId>
 <version>${quarkus.version}</version>
 <extensions>true</extensions>
 <executions>
 <execution>
 <goals><goal>build</goal></goals>
 </execution>
 </executions>
 </plugin>
 </plugins>
</build>

2. Configure

quarkus.atmosphere.packages=com.example.chat

Available Properties

3. Create the Chat Service

@ManagedService(path = "/atmosphere/chat",
 atmosphereConfig = "org.atmosphere.cpr.maxInactiveActivity=120000")
public class Chat {
 @Inject
 private AtmosphereResource r;
 @Inject
 private AtmosphereResourceEvent event;
 @Ready
 public void onReady() {
 // Connection is ready
 }
 @Disconnect
 public void onDisconnect() {
 if (event.isClosedByClient()) {
 // Client closed the connection
 }
 }
 @Message(encoders = {JacksonEncoder.class}, decoders = {JacksonDecoder.class})
 public Message onMessage(Message message) {
 return message;
 }
}

4. Run in Dev Mode

mvn quarkus:dev

Native Image

mvn package -Dnative
./target/atmosphere-quarkus-chat-4.0.0-runner

How It Works