beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [beam] 01/01: Merge pull request #4206 from jbonofre/BEAM-3282-MQTTIO
Date Tue, 09 Jan 2018 10:20:21 GMT
This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit ddc4a188363e21d5d9d89ffbbc84cbfb20c6284f
Merge: 65ab1cc d22fa01
Author: Jean-Baptiste Onofré <jbonofre@apache.org>
AuthorDate: Tue Jan 9 11:20:16 2018 +0100

    Merge pull request #4206 from jbonofre/BEAM-3282-MQTTIO
    
    [BEAM-3282] MqttIO reader now use receive for timeout in order to ret…

 .../java/org/apache/beam/sdk/io/mqtt/MqttIO.java   | 20 ++++++++++++++------
 .../org/apache/beam/sdk/io/mqtt/MqttIOTest.java    | 22 ++++++++++++++++++++--
 2 files changed, 34 insertions(+), 8 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <commits@beam.apache.org>.

Mime
View raw message