SmallRye Reactive Messaging : Connector :: MQTT Server

An implementation of the MicroProfile Reactive Streams Messaging specification

License

License

Categories

Categories

React User Interface Web Frameworks Messaging Application Layer Libs
GroupId

GroupId

io.smallrye.reactive
ArtifactId

ArtifactId

smallrye-reactive-messaging-mqtt-server
Last Version

Last Version

3.1.0
Release Date

Release Date

Type

Type

jar
Description

Description

SmallRye Reactive Messaging : Connector :: MQTT Server
An implementation of the MicroProfile Reactive Streams Messaging specification
Project Organization

Project Organization

SmallRye

Download smallrye-reactive-messaging-mqtt-server

How to add to project

<!-- https://jarcasting.com/artifacts/io.smallrye.reactive/smallrye-reactive-messaging-mqtt-server/ -->
<dependency>
    <groupId>io.smallrye.reactive</groupId>
    <artifactId>smallrye-reactive-messaging-mqtt-server</artifactId>
    <version>3.1.0</version>
</dependency>
// https://jarcasting.com/artifacts/io.smallrye.reactive/smallrye-reactive-messaging-mqtt-server/
implementation 'io.smallrye.reactive:smallrye-reactive-messaging-mqtt-server:3.1.0'
// https://jarcasting.com/artifacts/io.smallrye.reactive/smallrye-reactive-messaging-mqtt-server/
implementation ("io.smallrye.reactive:smallrye-reactive-messaging-mqtt-server:3.1.0")
'io.smallrye.reactive:smallrye-reactive-messaging-mqtt-server:jar:3.1.0'
<dependency org="io.smallrye.reactive" name="smallrye-reactive-messaging-mqtt-server" rev="3.1.0">
  <artifact name="smallrye-reactive-messaging-mqtt-server" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.smallrye.reactive', module='smallrye-reactive-messaging-mqtt-server', version='3.1.0')
)
libraryDependencies += "io.smallrye.reactive" % "smallrye-reactive-messaging-mqtt-server" % "3.1.0"
[io.smallrye.reactive/smallrye-reactive-messaging-mqtt-server "3.1.0"]

Dependencies

compile (5)

Group / Artifact Type Version
io.smallrye.reactive : smallrye-mutiny-vertx-mqtt jar 2.2.0
io.smallrye.reactive : smallrye-reactive-messaging-provider jar 3.1.0
org.jboss.logging : jboss-logging jar 3.4.1.Final
io.smallrye.reactive : smallrye-reactive-converter-api jar 2.2.0
io.smallrye.reactive : mutiny jar 0.14.0

provided (3)

Group / Artifact Type Version
io.smallrye.reactive : smallrye-connector-attribute-processor jar 3.1.0
org.jboss.logging : jboss-logging-annotations jar 2.2.1.Final
org.jboss.logging : jboss-logging-processor jar 2.2.1.Final

test (16)

Group / Artifact Type Version
org.jboss.weld : weld-junit5 jar 2.0.2.Final
io.smallrye.config : smallrye-config jar 2.2.0
io.vertx : vertx-junit5 jar
org.eclipse.paho : org.eclipse.paho.client.mqttv3 jar 1.2.5
org.jboss.weld.se : weld-se-core jar 3.1.6.Final
io.smallrye.reactive : mutiny-reactive-streams-operators jar 0.14.0
io.smallrye.reactive : smallrye-reactive-converter-rxjava2 jar 2.2.0
io.smallrye.reactive : smallrye-reactive-converter-reactor jar 2.2.0
io.smallrye.reactive : smallrye-reactive-converter-mutiny jar 2.2.0
org.junit.jupiter : junit-jupiter jar 5.7.1
org.junit.jupiter : junit-jupiter-api jar 5.7.1
org.assertj : assertj-core jar 3.19.0
org.awaitility : awaitility jar 4.0.3
org.mockito : mockito-all jar 1.10.19
org.junit-pioneer : junit-pioneer jar 1.3.8
org.junit.platform : junit-platform-commons jar 1.7.1

Project Modules

There are no modules declared in this project.

Maven Central Continuous Integration Build License

Implementation of the MicroProfile Reactive Messaging specification

This project is an implementation of the (next to be) Eclipse MicroProfile Reactive Messaging specification - a CDI extension to build event-driven microservices and data streaming applications. It provides support for:

It also provides a way to inject streams into CDI beans, and so link your Reactive Messaging streams into CDI beans,or JAX-RS resources.

Branches

  • main - 3.x development stream. Uses Vert.x 4.x and Microprofile 4.x
  • 2.x - 2.x development stream. Uses Vert.x 3.x and Microprofile 3.x

Getting started

Prerequisites

See PREREQUISITES.md for details.

The build process requires Apache Maven and Java 8+ and can be performed using:

mvn clean install

How to start

The best way to start is to look at the examples/quickstart project. It's a Maven project listing the minimal set of dependencies and containing a single class:

package io.smallrye.reactive.messaging.quickstart;

import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Outgoing;
import org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder;
import org.eclipse.microprofile.reactive.streams.operators.ReactiveStreams;

import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.se.SeContainerInitializer;

@ApplicationScoped
public class QuickStart {

  public static void main(String[] args) {
    SeContainerInitializer.newInstance().initialize();
  }


  @Outgoing("source")
  public PublisherBuilder<String> source() {
    return ReactiveStreams.of("hello", "with", "SmallRye", "reactive", "message");
  }

  @Incoming("source")
  @Outgoing("processed-a")
  public String toUpperCase(String payload) {
    return payload.toUpperCase();
  }

  @Incoming("processed-a")
  @Outgoing("processed-b")
  public PublisherBuilder<String> filter(PublisherBuilder<String> input) {
    return input.filter(item -> item.length() > 4);
  }

  @Incoming("processed-b")
  public void sink(String word) {
    System.out.println(">> " + word);
  }

}

Run the project with: mvn compile exec:java -Dexec.mainClass=io.smallrye.reactive.messaging.quickstart.QuickStart:

>> HELLO
>> SMALLRYE
>> REACTIVE
>> MESSAGE

Built With

Contributing

Please read CONTRIBUTING.md for details, and the process for submitting pull requests.

Sponsors

The project is sponsored by Red Hat.

License

This project is licensed under the Apache License 2.0 - see the LICENSE file for details.

io.smallrye.reactive

SmallRye

Versions

Version
3.1.0
3.0.0
3.0.0.RC2
3.0.0.RC1
2.9.0
2.8.0
2.7.1
2.7.0
2.6.1
2.6.0
2.5.0
2.4.0
2.3.0
2.2.1
2.2.0
2.1.1
2.1.0
2.0.4
2.0.3
2.0.2
2.0.1
2.0.0
1.1.0
1.0.8
1.0.7
1.0.6
1.0.4