2.1. [Job Data Flow](#TOS-Job-02)
2.2. [Write your own Job](#TOS-Job-03)
2.3. [Execute and Debug](#TOS-Job-04) 2. [Enterprise Service Bus](#TOC-ESB1)
3.1. [Routes](#TOC-ESB2)
3.1.1. [ActiveMQ Integration](#TOC-ESB3)
3.2. [Service Development](#TOC-ESB4)
3.2.1. [SOAP CRM service](#TOC-ESB5)
3.2.2. [REST Customers service](#TOC-ESB6)
3.3. [Service deployment](#TOC-ESB7)
3.3.1 [How to deploy service using ESBRuntime Container](#TOC-ESB8)
3.3.2. [deploy service using apache tomcat](#TOC-ESB9) 3. [Management and Monitoring](#TOC-ESB10)
4.1.1. [Hawtio](#TOC-ESB11)
- Download Java SE Development Kit 8 from Oracle Website.
- Install the downloaded package into local directory. The installation path must NOT contain white space.
- Configure path for JAVA_HOME.
- Download Talend Open Studio for ESB here
- Extract the downloaded package into your local directory. Ex: E:\Talend\01.DevTools
- Go into folder Studio [Ex: E:\Talend\01.DevTools\Studio] and run [TOS_ESB-win-x86_64.exe] in case of Win64bit or [TOS_ESB-win32-x86] in case of Win32bit to start Talend Open Studio for ESB.
After import successfully, the development view will be displayed as below:
On the Repository, open ProductJob 0.1. The design of ProjectJob 0.1 will be displayed.
- parseInputCSVfile: this component parses the input csv file.
- Default value and Validation: At this component, each csv record will be validated the data definition such as data length, data format, data type.etc... The invalid data will be marked for filtering in the next step. Default value is also assigned to the record at this step.
- Filter flag: At this step, the valid data will be transferred to the Reference check step. The invalid data will be moved to Log error component.
- References check: This step makes sure the input data having the valid reference. For example, when importing a product, the price list must be existed. The data having invalid reference will be marked.
- Filter data: The data with invalid reference will go to step Log error. The valid data will go to the final step Finish.
- Finish: At this component, all the valid data will be send to ERP server for importing purpose.
- Log Error: this component at step 7 and step 8 will log the invalid data.
This part will guide you steps to write your own simple job. To implement the job, you need the following palette tFileInputDelimited, tJavaRow, tFilterRow.
Step 1: At the Repository, Right Click on Job Design -> Create Job. Input the information for the new Job. Example: name = ProductSampleJob.
Step 2: Using the palette to draw the design as the following image.
Step 3: Select the tFileInputDelimited on the design, then select the Component tab: At the File name/Stream combobox, browse to the csv file. Modify CSV Row Separator, File Separator as in the above image.
Step 4: Select item rawData(Main), at the tab Component, click Edit Schema.
Next, click Import schema -> OK
Edit Schema -> click icon Copy all of the columns from the input schema to the output schema -> OK.
Step 6: Slect tfilterRow filterFlag, at the tab Component input the Condition to filter at the table Condition
Step 7: Write your code to log invalid data into the code textbox of the Component of the component LogRejectProduct and write your code to process valid data into the code textbox of the Component tab of component LogvalidatedProducts.
On the tab Run (Job ProductSampleJob), click Run to execute the job.
Right click on the component that you want to debug, select Add breakpoint.
On the tab ** Run (Job ProductSampleJob)**, select sub-tab Debug Run. On the dropbox Debug:
- Select Trace Debug if you want to run Debug in Trace mode.
- Select Java Debug if you want to run in Java debug mode.
Step 1: Start ActiveMQ server
Step 2: Run MQMultiReceiver job and MQMultiSender in Talend
The result id outputted on the console.
Step 1: Create service using talend open studio
Step 2: Create Job to expose SOAP
Step 3: Run job by click run button on Run tab
Step 4: Test SOAP using boomerang Test case 1: type http://localhost:8090/services/CRMServiceProvider in boomerang and enter id equals 1.
Test case 2: type http://localhost:8090/services/CRMServiceProvider in boomerang and enter id equals 2.
Test case 3: Start getCRMStatus function by click run button on run tab and type http://localhost:8090/services/CRMServiceProvider in boomerang and enter id equals 1.
Test case 4: Start getCRMStatus function by click run button on run tab and type http://localhost:8090/services/CRMServiceProvider in boomerang and enter id equals 2.
Test case 5: Start updateCRMStatus function by click run button on run tab and type http://localhost:8090/services/CRMServiceProvider in boomerang and update id equals 1.
The result is outputted on the console.
The REST API will be implemented in talend as the following
Step 1: Create data to runing REST API. select tFixedFieldInput_1->create data in component tab.
Step 2: Create request for REST API. select tRESTRequest_1->create request in component tab
Step 3: The Test is implemented on talend (Select Run(job DemoREST)-> Run) and Advanced REST client for chrome.
Test case 1: type http://localhost:8090/services/customers in Advanced REST client for chrome.
Test case 2: type http://localhost:8090/services/customers/1 in Advanced REST client for chrome.
Test case 3: type http://localhost:8090/services/customers/2 in Advanced REST client for chrome.
We are ready to deploy Talend ESB RESTful Service DemoREST-0.1 job to Talend Runtime environment for that we must build job from studio as OSGI Bundle for ESB
Select archive file path, Build type as OSGI Bundle For ESB and click Finish
exported file must be copied in Runtime_ESBSE/container/deploy folder
On Runtime container use list command to check status of your service.
Now we are able to deploy ESB job as service in Talend Runtime container using apache karaf but to make it run as a operating system service we must install Karaf Wrapper feature.
Installing the wrapper
Step 1: Browse to the container/bin folder of the Talend Runtime installation directory, then launch the container by executing the trun file as a root user.
Step 2: To install the wrapper feature, simply type:
Once installed, wrapper feature will provide wrapper:install new command in the trun, which allows you to install Talend Runtime as a service. Step 3: To register the container as a service in automatic start mode, simply type:
Now, We will test service from chrome brower. Step 1: To test the REST service, type http://10.10.10.1:8040/services/customers (you can replace 10.10.10.1:8040 by your deploy machine) in chrome brower.
