[BEAM-606] Create MqttIO by jbonofre · Pull Request #971 · apache/beam

[BEAM-606] Create MqttIO

jbonofre

committed

[BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue and improve tests.

jbonofre

committed

[BEAM-606] Set topic required. Move some subscriber specific MQTT code on the reader. Improve tests.

jbonofre

committed

[BEAM-606] Replace KV internal use with a regular POJO

jbonofre

committed

[BEAM-606] Use a better value for watermark

jbonofre

committed

[BEAM-606] Validation is now performed only in create(), maxNumRecords and maxReadTime are now exclusive, use ByteArrayCoder instead of SerializableCoder, use poll instead of take on the blocking q…

jbonofre

committed

[BEAM-606] Rename connection configuration, improve javadoc

jbonofre

committed

[BEAM-606] Refactore read test to be more reliable

jbonofre

committed

[BEAM-606] Update documentation, change the QoS in the test

jbonofre

committed

[BEAM-606] Start ActiveMQ broker on free network port in the tests

jbonofre

committed

[BEAM-606] Fix parent pom version

jbonofre

committed

[BEAM-606] Exclude support of QoS 2, cleanup in javadoc

jbonofre

committed

[BEAM-606] Add core MQTT test

jbonofre

committed

[BEAM-606] Improved checkpoint with manual ack, update comments about QoS (relationship between publisher and subsribers), auto generate clientId (reliability)

jbonofre

committed

[BEAM-606] Fix checkpoint mark

jbonofre

committed

[BEAM-606] Only support QoS 1 in Write, updated to last SDK changes

jbonofre

committed

[BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter

jbonofre

committed

[BEAM-606] Update parent version

jbonofre

committed

[BEAM-606] Fix checkpoint mark reusing the same MQTT client as in the source, fix on the tests

jbonofre

committed

[BEAM-606] Replace paho MQTT client lib by fusesource one providing ~ 30% better performances.

jbonofre

committed

[BEAM-606] Use spec to create MQTT client in write

jbonofre

committed

[BEAM-606] Rename LOGGER to LOG and add debug logging messages

jbonofre

committed

[BEAM-606] Set messages transient in the MqttCheckpointMark

jbonofre

committed

[BEAM-606] Use UUID to generate unique MQTT client ID, use blocking connection in write test

jbonofre

committed

[BEAM-606] Tests cleanup

jbonofre

committed

[BEAM-606] Fix checkstyle

jbonofre

committed

[BEAM-606] Fix preconditions messages

jbonofre

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[BEAM-606] Create MqttIO#971

[BEAM-606] Create MqttIO#971
jbonofre wants to merge 27 commits intoapache:masterfrom
jbonofre:BEAM-606-MQTTIO

Commits on Dec 23, 2016

[BEAM-606] Create MqttIO

[BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue and improve tests.

[BEAM-606] Set topic required. Move some subscriber specific MQTT code on the reader. Improve tests.

[BEAM-606] Replace KV internal use with a regular POJO

[BEAM-606] Use a better value for watermark

[BEAM-606] Validation is now performed only in create(), maxNumRecords and maxReadTime are now exclusive, use ByteArrayCoder instead of SerializableCoder, use poll instead of take on the blocking q…

[BEAM-606] Rename connection configuration, improve javadoc

[BEAM-606] Refactore read test to be more reliable

[BEAM-606] Update documentation, change the QoS in the test

[BEAM-606] Start ActiveMQ broker on free network port in the tests

[BEAM-606] Fix parent pom version

[BEAM-606] Exclude support of QoS 2, cleanup in javadoc

[BEAM-606] Add core MQTT test

[BEAM-606] Improved checkpoint with manual ack, update comments about QoS (relationship between publisher and subsribers), auto generate clientId (reliability)

[BEAM-606] Fix checkpoint mark

[BEAM-606] Only support QoS 1 in Write, updated to last SDK changes

[BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter

[BEAM-606] Update parent version

[BEAM-606] Fix checkpoint mark reusing the same MQTT client as in the source, fix on the tests

[BEAM-606] Replace paho MQTT client lib by fusesource one providing ~ 30% better performances.

[BEAM-606] Use spec to create MQTT client in write

[BEAM-606] Rename LOGGER to LOG and add debug logging messages

[BEAM-606] Set messages transient in the MqttCheckpointMark

[BEAM-606] Use UUID to generate unique MQTT client ID, use blocking connection in write test

[BEAM-606] Tests cleanup

[BEAM-606] Fix checkstyle

[BEAM-606] Fix preconditions messages