Thanks Gordon for looking into my query. It makes sense what u said,
however i am still searching for a reason of flow control and limited batch
size.

As per your suggestion i tried increasing the link-credit to 10k, 100k, but
that doesn't change much. my understanding of prefetch was that its number
of packets not the number of bytes (i confirmed this by reducing the
prefetch to 2 and then i see only 1 pkt per bulk message (half of the
window size)).

The size of the each pkt is roughly 900B, and as u can see that i am not
able to read more than 12 pkts per batch in the complete logs below. So
looking back yes the size of 12x900B is greater than 5KB, so the heading
may need correction - it looks like 2x of that which is 10kb.

would appreciate if someone can suggest some more knobs i should play to
figure out where this limit of 10kb is coming from ? client advertised
incoming_window is incoming-window=2147483647 <(214)%20748-3647>

see the complete logs, as u can see the bulk size is limited to 12 pkts,
where the link credit remains at 9999, after every bulk.


[0xb58380]:  -> SASL

[0xb58380]:  <- SASL

[0xb58380]:0 <- @sasl-mechanisms(64)
[sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS, :PLAIN, :ANONYMOUS, :EXTERNAL]]

[0xb58380]:0 -> @sasl-init(65) [mechanism=:PLAIN,
initial-response=b"\x0xxxx"]

[0xb58380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]

[0xb58380]:  -> AMQP

[0xb58380]:0 -> @open(16)
[container-id="bc599ddc-74df-46b0-800c-401aed27f321", hostname="
nebhubsb.servicebus.windows.net", channel-max=32767]

[0xb58380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
outgoing-window=2147483647]

[0xb58380]:0 -> @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0,
source=@source(40) [address="kukatopic/Subscriptions/kukasub", durable=0,
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=0]

[0xb58380]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0,
outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10000,
drain=false]

[0xb58380]:  <- AMQP

[0xb58380]:0 <- @open(16)
[container-id="fa8f5d5577be485ebd7f5ebdbdfd9ca1_G13", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]

[0xb58380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]

[0xb58380]:0 <- @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=false, rcv-settle-mode=1, source=@source(40)
[address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
initial-delivery-count=0, max-message-size=266240]

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=0,
delivery-tag=b"\x06\xa8\xb3\xf9\x94\x1b\x09H\xa0\xc7\xf2\x11\xd7I\xa9\x12",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xc7\x0a\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x15\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:29.4663961Z",
"iteration": 467375, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 97.599472}, "A2": {"units": "Double", "value": -88.2291565}, "A5":
{"units": "Double", "value": 80"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=1,
delivery-tag=b"P\xb1\x94N9\x18\x0bD\xb6\x00[cr#\x1d\xab", message-format=0,
more=false, batchable=true] (1245)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcb\x04\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x16\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03j{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:30.4976526Z",
"iteration": 467376, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.28403}, "A3": {"units": "Double",
"value": 90.7003937}, "A2": {"units": "Double", "value": -89.3041382},
"A5": {"units": "Double", "value": 88.6"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=2,
delivery-tag=b"\x12.\x19\xb4\x910\x8dE\x8a:\xf5\xbb\x96C\x1b\xc5",
message-format=0, more=false, batchable=true] (1248) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcf+\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x17\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03m{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:31.4820328Z",
"iteration": 467377, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -1.19551659}, "A3": {"units": "Double",
"value": 89.9831085}, "A2": {"units": "Double", "value": -89.9831161},
"A5": {"units": "Double", "value": 90."... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=3,
delivery-tag=b"\xd0C\xa4\xd9\xde\x9a\xa2E\xb4n>\xd6\x03=\x9dM",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd3\x13\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x18\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:32.4976359Z",
"iteration": 467378, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 92.8772888}, "A2": {"units": "Double", "value": -89.094696}, "A5":
{"units": "Double", "value": 8"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=4,
delivery-tag=b"r-\xa9{\xeb\xdd\xaaE\xb5$\xe1\xef\xa6\xf4\xaf\xae",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd7\x0b\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x19\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:33.4976551Z",
"iteration": 467379, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 103.376465}, "A2": {"units": "Double", "value": -86.0274429},
"A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=5,
delivery-tag=b"J@h8\x07\x9d\xf4C\x91j\x90\x96\xdd\x04\x9e\xc7",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xdb\x05\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1a\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:34.5132557Z",
"iteration": 467380, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.544}, "A2": {"units": "Double", "value": -83.1735153}, "A5":
{"units": "Double", "value": 65."... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=6,
delivery-tag=b"\x9bz\x89J\x90MSB\x8b*ZT\xd5\x89\x15\x95", message-format=0,
more=false, batchable=true] (1249)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xde\xf1\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1b\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03n{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:35.5290977Z",
"iteration": 467381, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.362862}, "A2": {"units": "Double", "value": -83.33}, "A5":
{"units": "Double", "value": 65.96"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=7,
delivery-tag=b"\x06\xbb\xaf\xdf\xe1^\xf5G\x9c\xf5e\xd1\xa7\xf6\xd5\xfb",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe3\x17\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1c\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:36.5758427Z",
"iteration": 467382, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 100.348694}, "A2": {"units": "Double", "value": -87.373642}, "A5":
{"units": "Double", "value": 7"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=8,
delivery-tag=b"\xa3\xc8\x93-\xfa\xa7IL\x93\xb4;\xaf\xc5\xb4\xc7\xa8",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe7\x0f\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1d\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:37.5225192Z",
"iteration": 467383, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.09980822}, "A3": {"units": "Double",
"value": 90.2022552}, "A2": {"units": "Double", "value": -89.3671265},
"A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=9,
delivery-tag=b"\x1d\x08\xf2\xe6\xb3\x1b\xa0F\xb0$p\xd2\xc9\xbe\xa5\x03",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xeb\x07\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1e\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:38.5225063Z",
"iteration": 467384, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.16081071}, "A3": {"units": "Double",
"value": 89.9449539}, "A2": {"units": "Double", "value": -89.9449844},
"A5": {"units": "Double", "value": 9"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=10,
delivery-tag=b"\xca\x0f\xc8S\x08UEB\x8fc\xa0c^\x95C[", message-format=0,
more=false, batchable=true] (1250)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xee\xfe\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1f\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:39.5381273Z",
"iteration": 467385, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 92.891922}, "A2": {"units": "Double", "value": -89.0930252}, "A5":
{"units": "Double", "value": 86"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=11,
delivery-tag=b"\xe2\xdf\xdd\xcc>\x93\xc3L\x83"o|\xb7`\x00\x16",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf2\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9
\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:40.5381136Z",
"iteration": 467386, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 93.7598724}, "A2": {"units": "Double", "value": -88.9818115},
"A5": {"units": "Double", "value": 85.2"... (truncated)

called from init

2017-08-09 06:35:07.092 1 11

2017-08-09 06:35:07.092 2 10

2017-08-09 06:35:07.093 3 9

2017-08-09 06:35:07.093 4 8

2017-08-09 06:35:07.093 5 7

2017-08-09 06:35:07.094 6 6

2017-08-09 06:35:07.094 7 5

2017-08-09 06:35:07.095 8 4

2017-08-09 06:35:07.095 9 3

2017-08-09 06:35:07.095 10 2

2017-08-09 06:35:07.096 11 1

2017-08-09 06:35:07.096 12 0

[0xb58380]:0 -> @flow(19) [next-incoming-id=13, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=12,
link-credit=9999, drain=false]

[0xb58380]:0 -> @disposition(21) [role=true, first=0, last=11,
settled=true, state=@accepted(36) []]

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=12,
delivery-tag=b"b\xe9\xde\x8c\x84\x81\x02@\x8dj\x92+\x1f\x09\xc0\x87",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf3\xf0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9!\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:42.986629-07:00",
"iteration": 41655, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=13,
delivery-tag=b"\xc29\xa2 \x90\xc9\x11E\xa7 y\x9f\x11\x09\x82\xaf",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf7\x0d\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9"\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:41.5693763Z",
"iteration": 467387, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.22507381}, "A3": {"units": "Double",
"value": 90.4831543}, "A2": {"units": "Double", "value": -89.3285599},
"A5": {"units": "Double", "value": 88.8"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=14,
delivery-tag=b"\xbeC\xf6#\x04LjL\x83^qn\x16]\x9af", message-format=0,
more=false, batchable=true] (1246)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfa\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9#\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03k{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:42.569343Z", "iteration":
467388, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 0.531275868}, "A3": {"units": "Double",
"value": 89.9966736}, "A2": {"units": "Double", "value": -89.9966736},
"A5": {"units": "Double", "value": 90.0"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=15,
delivery-tag=b"\xf4_\xa7\xba\xc8H\x02I\x83\xdd\xfb\x80\x82\xa0s\x80",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfe\xde\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9$\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:43.5537905Z",
"iteration": 467389, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.84453963e-08}, "A3": {"units":
"Double", "value": 90.0001831}, "A2": {"units": "Double", "value":
-90.0001831}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=16,
delivery-tag=b"\xa1\xe0M[\xa4H\x1eJ\x8d\x02v\x02\xe4\x0c\x14\x03",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x02\xd5\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9%\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:44.5850014Z",
"iteration": 467390, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.82398274e-08}, "A3": {"units":
"Double", "value": 90.222847}, "A2": {"units": "Double", "value":
-90.222847}, "A5": {"units": "Double", "value": 87"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=17,
delivery-tag=b"\xc9h|\x93\xb0\xe3\x98I\xb8\x18\xf64\x14\xd5\xbb\xf6",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x06\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9&\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:45.3687793Z",
"iteration": 467391, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.67124625e-08}, "A3": {"units":
"Double", "value": 91.8771896}, "A2": {"units": "Double", "value":
-91.8771896}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=18,
delivery-tag=b"Og\xdf\x07\x06\xa6\xf4@\xa2'\xb4\xfde\xd7\x13\xc6",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0a\xe6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9'\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:46.3844118Z",
"iteration": 467392, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.27457609e-08}, "A3": {"units":
"Double", "value": 96.1736755}, "A2": {"units": "Double", "value":
-96.1736755}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=19,
delivery-tag=b"\xb9\xc1\xa7za\xc76F\xb5i\x91\x83:\xce\xac\xaf",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0e\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9(\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:47.4000408Z",
"iteration": 467393, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.65389352e-09}, "A3": {"units":
"Double", "value": 101.688866}, "A2": {"units": "Double", "value":
-101.688866}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=20,
delivery-tag=b"\xbe87Z\xf5\xe6\x80B\x82\x0e>\x14\x8fr\xa4\xc9",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x12\xb7\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9)\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:48.4000176Z",
"iteration": 467394, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.82696688e-09}, "A3": {"units":
"Double", "value": 106.917091}, "A2": {"units": "Double", "value":
-106.917091}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=21,
delivery-tag=b"\x91\x0b\xc3\xe6\x86\xc1\x0aN\xbe\x83\xdfo,\x03b\xdf",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x13\xc0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9*\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:51.188902-07:00",
"iteration": 41656, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=22,
delivery-tag=b"f\x03R\xe8\x07\x0a\xf5O\xb2W\x1b\x7f\x8c\xe3O\xdc",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x16\xae\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9+\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:49.4156473Z",
"iteration": 467395, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.40006631e-10}, "A3": {"units":
"Double", "value": 109.827438}, "A2": {"units": "Double", "value":
-109.827438}, "A5": {"units": "Double", "value": "... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=23,
delivery-tag=b"\x08\xb6\xeb\x14 i\x8aA\xa8\xab\xffS\xdd\xd7\x8b\x83",
message-format=0, more=false, batchable=true] (1240) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1a\xa6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9,\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03e{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:50.446901Z", "iteration":
467396, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -2.46100844e-05}, "A3": {"units":
"Double", "value": 110.0}, "A2": {"units": "Double", "value": -110.0},
"A5": {"units": "Double", "value": -90.0}, "A"... (truncated)

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=24,
delivery-tag=b"\xce]\x1fC\xe7\xa7XO\x80\x96/\x1c\x9az\x12\xc6",
message-format=0, more=false, batchable=true] (1242) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1e\xcc\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9-\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03g{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:51.4468996Z",
"iteration": 467397, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -0.792964}, "A3": {"units": "Double",
"value": 109.94561}, "A2": {"units": "Double", "value": -109.923813}, "A5":
{"units": "Double", "value": -90.02"... (truncated)

2017-08-09 06:35:07.111 13 12

2017-08-09 06:35:07.111 14 11

2017-08-09 06:35:07.112 15 10

2017-08-09 06:35:07.112 16 9

2017-08-09 06:35:07.113 17 8

2017-08-09 06:35:07.113 18 7

2017-08-09 06:35:07.113 19 6

2017-08-09 06:35:07.114 20 5

2017-08-09 06:35:07.114 21 4

2017-08-09 06:35:07.115 22 3

2017-08-09 06:35:07.115 23 2

2017-08-09 06:35:07.115 24 1

2017-08-09 06:35:07.116 25 0

[0xb58380]:0 -> @flow(19) [next-incoming-id=26, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=25,
link-credit=9999, drain=false]

[0xb58380]:0 -> @disposition(21) [role=true, first=12, last=24,
settled=true, state=@accepted(36) []]

[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=25,
delivery-tag=b"\x98\x1e\xc8\xb6\xd3\xb4bK\x94\xa7\xf7\x9e\xf2\xe2\xeao",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93"\xc4\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9.\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:52.4781421Z",
"iteration": 467398, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -4.55131578}, "A3": {"units": "Double",
"value": 105.856033}, "A2": {"units": "Double", "value": -104.539864},
"A5": {"units": "Double", "value": -91.31"... (truncated)

On Mon, Aug 7, 2017 at 6:05 PM, Pankaj Bhagra <pans...@gmail.com> wrote:

> I am trying to extract bulk messages from azure SB.
>
> As per their documentation the azure SDK doesn't support bulk read message
> and recommends using the native amqp for the Azure Service Bus. White
> trying to negotiate a session with the azure SB, i noticed that independent
> of what client is requesting, the SB dials down the incoming_window=5000.
> This limits a max of 5000B send per bulk read, thus my consumer runs dry
> till the RTT (which is large for inter cloud) to fetch a new packet.
>
> Is this a restriction of the azure SB or am i not setting any/some of the
> parameters correctly from the client side to achieve the negotiated window
> size  > 5000B.
>
> I am using python proton MessagingHandler Class and clearly see that
> on_message is called for few pkts composing of buffer size ~5000B and then
> have to wait for the RTT delay to get the next batch.
>
> Any suggestion to work around this problem and get larger bulked message ?
> I can't reduce the RTT between the server and consumer. have some
> workaround for parallel consumers but would like to solve the bulk problem
> as that is most efficient way of achieving the high throughput.
>
> class Recv(MessagingHandler):
>
>     def __init__(self):
>
>         super(Recv, self).__init__(prefetch=100, auto_accept=True,
> auto_settle=True, peer_close_is_error=False)
>
>
>     def on_start(self, event):
>
>         conn = event.container.connect(connString)
>
>         event.container.create_receiver(conn, subscription)
>
>
>     def on_message(self, event):
>
>         print(event.message.body)
>
>         print datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3],
> self.count, event.receiver.queued
>
>
> [0xace380]:  -> SASL
>
> [0xace380]:  <- SASL
>
> [0xace380]:0 <- @sasl-mechanisms(64) 
> [sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS,
> :PLAIN, :ANONYMOUS, :EXTERNAL]]
>
> [0xace380]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\
> x00iothubroutes_XXXXX\XXXXX="]
>
> [0xace380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
>
> [0xace380]:  -> AMQP
>
> [0xace380]:0 -> @open(16) 
> [container-id="0ad171ca-cefa-4a27-a7dc-0520e5393fa5",
> hostname="nebhubsb.servicebus.windows.net", channel-max=32767]
>
> [0xace380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647
> <(214)%20748-3647>, outgoing-window=2147483647 <(214)%20748-3647>]
>
> [0xace380]:0 -> @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=true,
> snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
> dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
> initial-delivery-count=0, max-message-size=0]
>
> [0xace380]:0 -> @flow(19) [incoming-window=2147483647 <(214)%20748-3647>,
> next-outgoing-id=0, outgoing-window=2147483647 <(214)%20748-3647>,
> handle=0, delivery-count=0, link-credit=100, drain=false]
>
> [0xace380]:  <- AMQP
>
> [0xace380]:0 <- @open(16) 
> [container-id="b970f07881334c658eb80ff336f2a683_G16",
> max-frame-size=65536, channel-max=4999, idle-time-out=240000]
>
> [0xace380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
> incoming-window=5000, outgoing-window=2147483647 <(214)%20748-3647>,
> handle-max=255]
>
> [0xace380]:0 <- @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=false,
> rcv-settle-mode=1, source=@source(40) [address="topic/Subscriptions/sub",
> durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
> timeout=0, dynamic=false], initial-delivery-count=0,
> max-message-size=266240]
>
>
>
>

Reply via email to