Skip to content

[BEAM-606] Create MqttIO #971

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
jbonofre wants to merge 27 commits into from
Closed

[BEAM-606] Create MqttIO #971

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
27 commits
Select commit Hold shift + click to select a range
5de6cf1
[BEAM-606] Create MqttIO
jbonofre Sep 12, 2016
9cd1d06
[BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue …
jbonofre Sep 23, 2016
58e7709
[BEAM-606] Set topic required. Move some subscriber specific MQTT cod…
jbonofre Oct 5, 2016
2a27bff
[BEAM-606] Replace KV internal use with a regular POJO
jbonofre Oct 5, 2016
b212efc
[BEAM-606] Use a better value for watermark
jbonofre Oct 5, 2016
dd48a7d
[BEAM-606] Validation is now performed only in create(), maxNumRecord…
jbonofre Oct 10, 2016
52c3cde
[BEAM-606] Rename connection configuration, improve javadoc
jbonofre Oct 13, 2016
6483580
[BEAM-606] Refactore read test to be more reliable
jbonofre Oct 13, 2016
3b44312
[BEAM-606] Update documentation, change the QoS in the test
jbonofre Oct 21, 2016
eb31df8
[BEAM-606] Start ActiveMQ broker on free network port in the tests
jbonofre Nov 2, 2016
ec93b77
[BEAM-606] Fix parent pom version
jbonofre Nov 2, 2016
911e98b
[BEAM-606] Exclude support of QoS 2, cleanup in javadoc
jbonofre Nov 3, 2016
655b53e
[BEAM-606] Add core MQTT test
jbonofre Nov 14, 2016
134cca0
[BEAM-606] Improved checkpoint with manual ack, update comments about…
jbonofre Nov 22, 2016
2d43072
[BEAM-606] Fix checkpoint mark
jbonofre Dec 5, 2016
b3c3f3c
[BEAM-606] Only support QoS 1 in Write, updated to last SDK changes
jbonofre Dec 9, 2016
ca3eec8
[BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter
jbonofre Dec 10, 2016
8730e0a
[BEAM-606] Update parent version
jbonofre Dec 14, 2016
0bbfe7e
[BEAM-606] Fix checkpoint mark reusing the same MQTT client as in the…
jbonofre Dec 14, 2016
463e0a3
[BEAM-606] Replace paho MQTT client lib by fusesource one providing ~…
jbonofre Dec 18, 2016
8d63a79
[BEAM-606] Use spec to create MQTT client in write
jbonofre Dec 18, 2016
bef0176
[BEAM-606] Rename LOGGER to LOG and add debug logging messages
jbonofre Dec 19, 2016
a12c708
[BEAM-606] Set messages transient in the MqttCheckpointMark
jbonofre Dec 20, 2016
0116624
[BEAM-606] Use UUID to generate unique MQTT client ID, use blocking c…
jbonofre Dec 20, 2016
14ae4ea
[BEAM-606] Tests cleanup
jbonofre Dec 20, 2016
2554928
[BEAM-606] Fix checkstyle
jbonofre Dec 21, 2016
2c51524
[BEAM-606] Fix preconditions messages
jbonofre Dec 23, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
152 changes: 152 additions & 0 deletions sdks/java/io/mqtt/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,152 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<parent>
<groupId>org.apache.beam</groupId>
<artifactId>beam-sdks-java-io-parent</artifactId>
<version>0.5.0-incubating-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>

<artifactId>beam-sdks-java-io-mqtt</artifactId>
<name>Apache Beam :: SDKs :: Java :: IO :: MQTT</name>
<description>IO to read and write to a MQTT broker.</description>

<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId>
</plugin>
</plugins>
</build>

<properties>
<activemq.version>5.13.1</activemq.version>
</properties>

<dependencies>
<dependency>
<groupId>org.apache.beam</groupId>
<artifactId>beam-sdks-java-core</artifactId>
</dependency>

<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</dependency>

<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
</dependency>

<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
</dependency>

<dependency>
<groupId>org.fusesource.mqtt-client</groupId>
<artifactId>mqtt-client</artifactId>
<version>1.14</version>
</dependency>
<dependency>
<groupId>org.fusesource.hawtbuf</groupId>
<artifactId>hawtbuf</artifactId>
<version>1.11</version>
</dependency>

<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
</dependency>

<!-- compile dependencies -->
<dependency>
<groupId>com.google.auto.value</groupId>
<artifactId>auto-value</artifactId>
<scope>provided</scope>
</dependency>

<!-- test -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-broker</artifactId>
<version>${activemq.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-mqtt</artifactId>
<version>${activemq.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-kahadb-store</artifactId>
<version>${activemq.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.beam</groupId>
<artifactId>beam-runners-direct-java</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.hamcrest</groupId>
<artifactId>hamcrest-all</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-jdk14</artifactId>
<scope>test</scope>
</dependency>
</dependencies>

</project>
Loading