diff --git a/opcua_plugin/opcua.go b/opcua_plugin/opcua.go
index 2b54ae59..2c57530d 100644
--- 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 {