@@ -438,14 +438,15 @@ private void indexByEnvironment(TurAemEnv turAemEnv, String snSite,
438
438
@ NotNull TurAemObject aemObject , TurAemModel turAemModel ,
439
439
List <TurSNAttributeSpec > turSNAttributeSpecList ,
440
440
TurAemSourceContext turAemSourceContext ,
441
- TurConnectorSession turConnectorSession ,
441
+ TurConnectorSession session ,
442
442
TurAemContentDefinitionProcess turAemContentDefinitionProcess ,
443
443
boolean standalone ) {
444
444
turAemSourceContext .setEnvironment (turAemEnv );
445
- turConnectorSession .setSites (Collections .singletonList (snSite ));
445
+ turAemSourceContext .setTurSNSite (snSite );
446
+ session .setSites (Collections .singletonList (snSite ));
446
447
sendToTuringToBeIndexed (aemObject , turAemModel , turSNAttributeSpecList ,
447
448
TurAemCommonsUtils .getLocaleFromAemObject (turAemSourceContext , aemObject ),
448
- turAemSourceContext , turConnectorSession , turAemContentDefinitionProcess , standalone );
449
+ turAemSourceContext , session , turAemContentDefinitionProcess , standalone );
449
450
}
450
451
451
452
private static boolean isPublish (TurAemSource turAemSource ) {
@@ -461,7 +462,7 @@ private static boolean isAuthor(TurAemSource turAemSource) {
461
462
private void sendToTuringToBeIndexed (TurAemObject aemObject , TurAemModel turAemModel ,
462
463
List <TurSNAttributeSpec > turSNAttributeSpecList , Locale locale ,
463
464
TurAemSourceContext turAemSourceContext ,
464
- TurConnectorSession turConnectorSession ,
465
+ TurConnectorSession session ,
465
466
TurAemContentDefinitionProcess turAemContentDefinitionProcess ,
466
467
boolean standalone ) {
467
468
turConnectorContext .addJobItem (
@@ -470,7 +471,7 @@ private void sendToTuringToBeIndexed(TurAemObject aemObject, TurAemModel turAemM
470
471
turSNAttributeSpecList ,
471
472
locale ,
472
473
turAemSourceContext ,
473
- turConnectorSession ,
474
+ session ,
474
475
turAemContentDefinitionProcess ,
475
476
getJobItemAttributes (
476
477
turAemSourceContext ,
@@ -480,7 +481,7 @@ private void sendToTuringToBeIndexed(TurAemObject aemObject, TurAemModel turAemM
480
481
turSNAttributeSpecList ,
481
482
turAemSourceContext ,
482
483
turAemContentDefinitionProcess ))),
483
- turConnectorSession ,
484
+ session ,
484
485
standalone );
485
486
}
486
487
@@ -502,12 +503,12 @@ private void sendToTuringToBeIndexed(TurAemObject aemObject, TurAemModel turAemM
502
503
List <TurSNAttributeSpec > turSNAttributeSpecList ,
503
504
Locale locale ,
504
505
TurAemSourceContext turAemSourceContext ,
505
- TurConnectorSession turConnectorSession ,
506
+ TurConnectorSession session ,
506
507
TurAemContentDefinitionProcess turAemContentDefinitionProcess ,
507
508
Map <String , Object > attributes ) {
508
509
TurSNJobItem jobItem = new TurSNJobItem (
509
510
TurSNJobAction .CREATE ,
510
- turConnectorSession .getSites ().stream ().toList (),
511
+ session .getSites ().stream ().toList (),
511
512
locale ,
512
513
attributes ,
513
514
TurAemCommonsUtils .castSpecToJobSpec (
0 commit comments