You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/12/23 07:02:31 UTC
[2/2] incubator-beam git commit: [BEAM-606] This closes #971
[BEAM-606] This closes #971
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b7d8c2c2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b7d8c2c2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b7d8c2c2
Branch: refs/heads/master
Commit: b7d8c2c205f37e11f2547b9a11fe3db2c8943204
Parents: aebe067 7bf86c7
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Fri Dec 23 08:02:02 2016 +0100
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Fri Dec 23 08:02:02 2016 +0100
----------------------------------------------------------------------
sdks/java/io/mqtt/pom.xml | 152 +++++
.../org/apache/beam/sdk/io/mqtt/MqttIO.java | 588 +++++++++++++++++++
.../apache/beam/sdk/io/mqtt/package-info.java | 22 +
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 197 +++++++
sdks/java/io/pom.xml | 1 +
5 files changed, 960 insertions(+)
----------------------------------------------------------------------