fixed bug that was causing a manual read even though in susbcribe mode

united-manufacturing-hub · Jul 17, 2024 · 207b089 · 207b089
1 parent bdd267c
commit 207b089
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/opcua_plugin/opcua.go b/opcua_plugin/opcua.go
@@ -688,8 +688,14 @@ func (g *OPCUAInput) ReadBatchSubscribe(ctx context.Context) (service.MessageBat
 func (g *OPCUAInput) ReadBatch(ctx context.Context) (msgs service.MessageBatch, ackFunc service.AckFunc, err error) {
 	if g.SubscribeEnabled {
 		msgs, ackFunc, err = g.ReadBatchSubscribe(ctx)
+	} else {
+		msgs, ackFunc, err = g.ReadBatchPull(ctx)
+	}
+
+	if err != nil {
+		g.Log.Error("Received error in ReadBatch: " + err.Error())
+		return nil, nil, err
 	}
-	msgs, ackFunc, err = g.ReadBatchPull(ctx)
 
 	// Heartbeat logic
 	if g.UseHeartbeat {