Edge SDK - Thingworx-common-6.0.2 : Could not bind things: Client binding limit exceeded.

[Aniruddha70]

Hi All,

We are using Thingworx-common-6.0.2.jar and Thingworx 7.4.8-b39

We use single edge client connection to update properties of multiple remote things

code works OK when we test with 50 devices , we get below exception when tested with 500 devices

##############################################

code - com.thingworx.communications.client.ConnectedThingClient.java

public void bind(List<String> things)
/* */ throws Exception
/* */ {
/* 362 */ BindRequestMessage bind = new BindRequestMessage();
/* */
/* 364 */ bind.getRequestContext().setRequestId(UniqueID.globalCounter());
/* 365 */ bind.getRequestContext().setMethod(RESTAPIConstants.Method.BINDREQUEST);
/* 366 */ bind.getRequestContext().setNames(things);
/* */
/* 368 */ if ((StringUtilities.isNonEmpty(getClientConfigurator().getName())) && (StringUtilities.isNonEmpty(getClientConfigurator().getType()))) {
/* 369 */ bind.getRequestContext().setGatewayName(getClientConfigurator().getName());
/* 370 */ bind.getRequestContext().setGatewayType(getClientConfigurator().getType());
/* 371 */ bind.getRequestContext().getNames().add(bind.getRequestContext().getGatewayName());
/* */ }
/* */
/* 374 */ ResponseMessage response = getEndpoint().sendRequest(bind);
/* */
/* 376 */ if (response.getResponseContext().getResultCode() != RESTAPIConstants.StatusCode.STATUS_SUCCESS) {
/* 377 */ throw new Exception("Could not bind things: " + response.getResponseContext().getResultMessage());
/* */ }
/* */
/* 380 */ for (String thingName : things) {
/* 381 */ getThing(thingName).setBound(true);
/* */ }
/* */ }

#######################################

Error -

java.lang.Exception: Could not bind things: Client binding limit exceeded.

        at com.thingworx.communications.client.ConnectedThingClient.bind(ConnectedThingClient.java:377)

        at com.thingworx.communications.client.ConnectedThingClient.bind(ConnectedThingClient.java:342)

        at com.thingworx.communications.client.ConnectedThingClient.bindThing(ConnectedThingClient.java:202)

        at com.techm.tnt.protocol.gateway.brokerConsumer.KafkaRecordProcessor.updateDeviceData(KafkaRecordProcessor.java:181)

        at com.techm.tnt.protocol.gateway.brokerConsumer.KafkaRecordProcessor.run(KafkaRecordProcessor.java:115)

        at java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1402)

        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)

        at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)

        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)