Skip to content

Commit 0cd5928

Browse files
committed
comma condition added
1 parent ddd145a commit 0cd5928

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

BlockBlobReader/src/consumer.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,8 @@ function messageHandler(serviceBusTask, context, sumoClient) {
361361
serviceBusTask.endByte -= JSON_BLOB_TAIL_BYTES;
362362
if (serviceBusTask.startByte <= JSON_BLOB_HEAD_BYTES) {
363363
serviceBusTask.startByte = JSON_BLOB_HEAD_BYTES;
364+
} else {
365+
serviceBusTask.startByte -= 1; //to remove comma before json object
364366
}
365367
file_ext = "nsg";
366368
}

BlockBlobReader/target/consumer_build/BlobTaskConsumer/index.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,8 @@ function messageHandler(serviceBusTask, context, sumoClient) {
361361
serviceBusTask.endByte -= JSON_BLOB_TAIL_BYTES;
362362
if (serviceBusTask.startByte <= JSON_BLOB_HEAD_BYTES) {
363363
serviceBusTask.startByte = JSON_BLOB_HEAD_BYTES;
364+
} else {
365+
serviceBusTask.startByte -= 1; //to remove comma before json object
364366
}
365367
file_ext = "nsg";
366368
}

BlockBlobReader/target/dlqprocessor_build/DLQTaskConsumer/index.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,8 @@ function messageHandler(serviceBusTask, context, sumoClient) {
361361
serviceBusTask.endByte -= JSON_BLOB_TAIL_BYTES;
362362
if (serviceBusTask.startByte <= JSON_BLOB_HEAD_BYTES) {
363363
serviceBusTask.startByte = JSON_BLOB_HEAD_BYTES;
364+
} else {
365+
serviceBusTask.startByte -= 1; //to remove comma before json object
364366
}
365367
file_ext = "nsg";
366368
}

0 commit comments

Comments
 (0)