cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Missing docs in kafka and vertx implementation (#183) 

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
This commit is contained in:
Francesco Guardiani 2020-06-23 17:20:25 +02:00 committed by GitHub
parent 83d9045897
commit 12cca34d21
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
http/vertx/pom.xml
View File

@ -37,6 +37,13 @@
</properties>
<dependencies>
<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
<version>3.0.2</version>
<scope>provided</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>io.cloudevents</groupId>
<artifactId>cloudevents-core</artifactId>

2
http/vertx/src/main/java/io/cloudevents/http/vertx/VertxMessageFactory.java
View File

@ -14,12 +14,14 @@ import io.vertx.core.*;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.http.*;
import javax.annotation.ParametersAreNonnullByDefault;
import java.util.function.Consumer;
/**
* This class provides a collection of methods to create {@link io.cloudevents.core.message.MessageReader}
* and {@link io.cloudevents.core.message.MessageWriter} for Vert.x HTTP Client and Server.
*/
@ParametersAreNonnullByDefault
public final class VertxMessageFactory {
private VertxMessageFactory() {

7
kafka/pom.xml
View File

@ -36,6 +36,13 @@
</properties>
<dependencies>
<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
<version>3.0.2</version>
<scope>provided</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>io.cloudevents</groupId>
<artifactId>cloudevents-core</artifactId>

3
kafka/src/main/java/io/cloudevents/kafka/KafkaMessageFactory.java
View File

@ -30,10 +30,13 @@ import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.header.Headers;
import javax.annotation.ParametersAreNonnullByDefault;
/**
* This class provides a collection of methods to create {@link io.cloudevents.core.message.MessageReader}
* and {@link io.cloudevents.core.message.MessageWriter} for Kafka Producer and Consumer.
*/
@ParametersAreNonnullByDefault
public final class KafkaMessageFactory {
private KafkaMessageFactory() {