Logic steps:
- Create a database connection as Oracle database or dbaas
- Create a db table and insert records with status as NEW.
- Create an app driven orchestration integration and configure db polling where
- Logical delete field = Status
- Read value= PROCESSED
- Unread value = NEW
- Rejected value =REJECTED
- POLLING Frequency = 30 sec
- Add a switch and check if the record has non empty email id and then write them to a ftp ditectory.
- Else configure db adpater invoke and update the status as ERROR and update date using current-dateTime() function.
Notes:
- Support for processing message payloads up to 10 MB in size. In the case of polling, we must set the Rejected value property to REJECTED on the polling strategy and options page. If the incoming message is greater than 10 MB threshold size, that particular record is updated to REJECTED instead of read or new.
- For each db record each instance will be created.
Create table query:
Create table SD_EMPLOYEE_Test(
ID NUMBER PRIMARY KEY,
FirstName VARCHAR2(200),
LastName VARCHAR2(200),
Department VARCHAR2(100),
Age NUMBER,
EmailAddress VARCHAR2(100),
Status VARCHAR2(10),
CreateDate Date,
UpdateDate Date
);
Detailed steps with screenshots:
Integration flow:
6 records added with status as NEW
After activating the integration, we can see, 5 records processed and 1 in ERROR as no email id.
No comments:
Post a Comment