Measurement listener stop recieving new measurement after few hour

vikash_singh6 · November 20, 2023, 2:19pm

Product/components used and version/fix level:

1016.0.264

Detailed explanation of the problem:

I have used MeasurementRealtimeNotificationSubscriber and subscribe for the measurement recieved on Device .its working fine in local.but when i have deployed this on cloud c8y its working for few hour and then stopped listening for new measurement.i have given 2 cpu 4Gb ram for microservice.

here is error logs:

ERROR 13 — [CumulocityLongPollingTransport-scheduler-2] c.s.i.s.n.NotificationServiceHelper : An error occurred for the measurement subscription

com.cumulocity.sdk.client.notification.ReconnectedSDKException: bayeux client reconnected clientId: 12duh3q0jkslwuaa89k9wgtn57i
at com.cumulocity.sdk.client.notification.SubscriberImpl.resubscribeAll(SubscriberImpl.java:192)
at com.cumulocity.sdk.client.notification.SubscriberImpl.access$900(SubscriberImpl.java:39)
at com.cumulocity.sdk.client.notification.SubscriberImpl$ReconnectOnSuccessfulConnected.rcvMeta(SubscriberImpl.java:273)
at org.cometd.common.AbstractClientSession.extendRcv(AbstractClientSession.java:99)
at org.cometd.common.AbstractClientSession.receive(AbstractClientSession.java:221)
at org.cometd.client.BayeuxClient$7.postCreate(BayeuxClient.java:630)
at org.cometd.client.BayeuxClient.changeState(BayeuxClient.java:971)
at org.cometd.client.BayeuxClient.processHandshake(BayeuxClient.java:613)
at org.cometd.client.BayeuxClient$HandshakeTransportListener.processMessage(BayeuxClient.java:1088)
at org.cometd.client.BayeuxClient$PublishTransportListener.onMessages(BayeuxClient.java:1066)
at com.cumulocity.sdk.client.notification.MessageExchange$ResponseConsumer.handleContent(MessageExchange.java:266)
at com.cumulocity.sdk.client.notification.MessageExchange$ResponseConsumer.getMessagesFromResponse(MessageExchange.java:209)
at com.cumulocity.sdk.client.notification.MessageExchange$ResponseConsumer.run(MessageExchange.java:156)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)

github.com

SoftwareAG/cumulocity-microservice-templates/blob/main/realtime/src/main/java/com/c8y/ms/templates/realtime/controller/NotificationController.java#L121


      
          
          /**
           * Subscribe for device updates. In this case the subscription is done for a
           * specific device but using the wildcard character * you can subscribe for
           * measurements of all devices. Be careful with this as this will result in a
           * lot of measurements. For subscription a custom class
           * MeasurementRealtimeNotificationSubscriber has been implemented which allows
           * to subscribe on the measurement channel to receive updates when a new
           * measurement has been created
           */
          private void registerForMeasurementUpdates(PlatformParameters platform) {
              final MeasurementRealtimeNotificationSubscriber subscriber = new MeasurementRealtimeNotificationSubscriber(platform);
              measurementSubscription = subscriber.subscribe(deviceId, new SubscriptionListener<>() {
                  @Override
                  public void onNotification(Subscription<String> arg0, MeasurementNotification notification) {
                      final MeasurementRepresentation measurement = jsonParser.parse(MeasurementRepresentation.class, json.forValue(notification.getData()));
                      LOG.info("new measurement received: {}", measurement.toJSON());
                  }
          
                  @Override
                  public void onError(Subscription<String> arg0, Throwable arg1) {

Error messages / full error message screenshot / log file:

Question related to a free trial, or to a production (customer) instance?

system · May 18, 2024, 2:19pm

This topic was automatically closed 180 days after the last reply. New replies are no longer allowed.