From 60fdb9ee3d16c3bbece9efaa6de38c7b3f69a581 Mon Sep 17 00:00:00 2001
From: Tomohito Nakayama <tmnk@nysalor.local>
Date: Mon, 18 Apr 2016 21:28:12 +0900
Subject: [PATCH] Changed to sendBatch

---
 examples/simple_sample_device_json.filed.js | 21 +++++++++++++++------
 1 file changed, 15 insertions(+), 6 deletions(-)

diff --git a/examples/simple_sample_device_json.filed.js b/examples/simple_sample_device_json.filed.js
index a1ab636..7fd1af4 100644
--- a/examples/simple_sample_device_json.filed.js
+++ b/examples/simple_sample_device_json.filed.js
@@ -6,10 +6,10 @@
 
 'use strict';
 
-var Protocol = require('azure-iot-device-amqp').Amqp;
+//var Protocol = require('azure-iot-device-amqp').Amqp;
 // Uncomment one of these transports and then change it in fromConnectionString to test other transports
-// var Protocol = require('azure-iot-device-amqp-ws').AmqpWs;
-// var Protocol = require('azure-iot-device-http').Http;
+//var Protocol = require('azure-iot-device-amqp-ws').AmqpWs;
+var Protocol = require('azure-iot-device-http').Http;
 // var Protocol = require('azure-iot-device-mqtt').Mqtt;
 var Client = require('azure-iot-device').Client;
 var Message = require('azure-iot-device').Message;
@@ -57,15 +57,24 @@ var connectCallback = function (err) {
       ( err ) => { console.log(err) } )
     .pass(
       ( result ) => {
+
+        let messages = [];
+
         for( let item of result.items ){
           var data = JSON.stringify(item);
           var message = new Message(data);
           message.properties.add('myproperty', 'myvalue');
-          console.log('Sending message: ' + message.getData());
-          client.sendEvent(message, printResultFor('send'));
+          messages.push(message);
+
         }
 
-        //client.close( ( err ) => { if( ! err ) { console.log('closed.') } } );
+        client.sendEventBatch(messages,
+          () => {
+            client.close(
+              ( err ) => { if( ! err ) { console.log('closed.') } }
+            );
+          }
+        );
 
       }
     ).exec();