Skip to content

Commit 61359e6

Browse files
author
Joerg Huber
committed
Use BaseSBPDemoSubscriber.
1 parent 212c8e9 commit 61359e6

7 files changed

Lines changed: 16 additions & 53 deletions

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/.gitignore‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
/AssessmentSubTestSubscriber.java
2+
/StudentScoreSetSubscriber.java

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/IdentitySubscriber.java‎

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -22,23 +22,16 @@
2222
import openadk.library.infra.InfraDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class IdentitySubscriber extends SBPBaseSubscriber
28+
public class IdentitySubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public IdentitySubscriber(String subscriberID)
3231
{
3332
super(subscriberID, InfraDTD.IDENTITY);
3433
}
3534

36-
@Override
37-
public void finalise()
38-
{
39-
logger.debug("...in finalise for "+getId() );
40-
}
41-
4235
@Override
4336
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
4437
{

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/SchoolInfoSubscriber.java‎

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -22,23 +22,16 @@
2222
import openadk.library.school.SchoolDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class SchoolInfoSubscriber extends SBPBaseSubscriber
28+
public class SchoolInfoSubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public SchoolInfoSubscriber(String subscriberID)
3231
{
3332
super(subscriberID, SchoolDTD.SCHOOLINFO);
3433
}
3534

36-
@Override
37-
public void finalise()
38-
{
39-
logger.debug("...in finalise for "+getId() );
40-
}
41-
4235
@Override
4336
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
4437
{

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/StaffPersonalSubscriber.java‎

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -22,23 +22,16 @@
2222
import openadk.library.student.StudentDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class StaffPersonalSubscriber extends SBPBaseSubscriber
28+
public class StaffPersonalSubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public StaffPersonalSubscriber(String subscriberID)
3231
{
3332
super(subscriberID, StudentDTD.STAFFPERSONAL);
3433
}
3534

36-
@Override
37-
public void finalise()
38-
{
39-
logger.debug("...in finalise for "+getId() );
40-
}
41-
4235
@Override
4336
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
4437
{

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/StudentContactRelationshipSubscriber.java‎

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,10 @@
2222
import openadk.library.student.StudentDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class StudentContactRelationshipSubscriber extends SBPBaseSubscriber
28+
public class StudentContactRelationshipSubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public StudentContactRelationshipSubscriber(String subscriberID)
3231
{
@@ -41,13 +40,6 @@ public StudentContactRelationshipSubscriber(String subscriberID)
4140
// query.addCondition( StudentDTD.STUDENTCONTACTRELATIONSHIP_CONTACTSEQUENCE, ComparisonOperators.EQ, "1" );
4241
// }
4342

44-
45-
@Override
46-
public void finalise()
47-
{
48-
logger.debug("...in finalise for "+getId() );
49-
}
50-
5143
@Override
5244
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
5345
{

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/StudentPersonalSubscriber.java‎

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,10 @@
2222
import openadk.library.student.StudentDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class StudentPersonalSubscriber extends SBPBaseSubscriber
28+
public class StudentPersonalSubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public StudentPersonalSubscriber(String subscriberID)
3231
{
@@ -40,12 +39,6 @@ public StudentPersonalSubscriber(String subscriberID)
4039
// }
4140

4241

43-
@Override
44-
public void finalise()
45-
{
46-
logger.debug("...in finalise for "+getId() );
47-
}
48-
4942
@Override
5043
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
5144
{
@@ -67,5 +60,4 @@ public boolean doesObjectExistInTargetSystem(String sifObjectName, List<SIFObjec
6760
// TODO Auto-generated method stub
6861
return false;
6962
}
70-
71-
}
63+
}

‎SBPDemo/sbpdemo/src/sbpdemo/subscriber/StudentSchoolEnrollmentSubscriber.java‎

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -22,23 +22,16 @@
2222
import openadk.library.student.StudentDTD;
2323
import sbpdemo.utils.DemoHelper;
2424
import systemic.sif.sbpframework.persist.model.SIFObjectKey;
25-
import systemic.sif.sbpframework.subscriber.SBPBaseSubscriber;
2625
import systemic.sif.sifcommon.mapping.MappingInfo;
2726
import systemic.sif.sifcommon.model.SIFEvent;
2827

29-
public class StudentSchoolEnrollmentSubscriber extends SBPBaseSubscriber
28+
public class StudentSchoolEnrollmentSubscriber extends BaseSBPDemoSubscriber
3029
{
3130
public StudentSchoolEnrollmentSubscriber(String subscriberID)
3231
{
3332
super(subscriberID, StudentDTD.STUDENTSCHOOLENROLLMENT);
3433
}
3534

36-
@Override
37-
public void finalise()
38-
{
39-
logger.debug("...in finalise for "+getId() );
40-
}
41-
4235
@Override
4336
public void processEvent(SIFEvent sifEvent, Zone zone, MappingInfo mappingInfo, String consumerID) throws ADKException
4437
{
@@ -57,8 +50,13 @@ public void processResponse(SIFDataObject sifObject, Zone zone, MappingInfo mapp
5750
@Override
5851
public boolean doesObjectExistInTargetSystem(String sifObjectName, List<SIFObjectKey> keyValues, SIFDataObject sifObject)
5952
{
60-
// TODO Auto-generated method stub
61-
return false;
53+
logger.debug(getId()+": Check Dependency for "+sifObjectName+" with key values: "+keyValues);
54+
boolean exists = false;
55+
56+
logger.debug(getId()+": Object ofr Dependency "+sifObjectName+" with key values: "+keyValues+" exists: "+exists);
57+
58+
59+
return exists;
6260
}
6361

6462
}

0 commit comments

Comments
 (0)