This is an automated email from the ASF dual-hosted git repository.
marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new 7acfcf23 Fix #1384
7acfcf23 is described below
commit 7acfcf23680146489c4924f2f93724a22c2a00e3
Author: Marat Gubaidullin <[email protected]>
AuthorDate: Wed Aug 28 11:24:52 2024 -0400
Fix #1384
---
karavan-core/test/topology3.camel.yaml | 135 +--------------------------------
1 file changed, 2 insertions(+), 133 deletions(-)
diff --git a/karavan-core/test/topology3.camel.yaml
b/karavan-core/test/topology3.camel.yaml
index b40fc0cf..64643421 100644
--- a/karavan-core/test/topology3.camel.yaml
+++ b/karavan-core/test/topology3.camel.yaml
@@ -1,10 +1,10 @@
- route:
id: route-6312
- description: Roster File Send
+ description: File Send
nodePrefixId: route-b7f
autoStartup: true
from:
- id: roster-file-send-direct
+ id: file-send-direct
uri: direct
parameters:
name: send-roster-files
@@ -13,137 +13,6 @@
- log:
id: log-894b
message: "DEBUG: Transfer Starting ${date:now:yyyyMMdd hh:mm:ss}"
- - split:
- id: split-135e
- description: Loop over filenames
- expression:
- simple:
- id: simple-9c24
- expression: ${variables.global:fileNames}
- steps:
- - log:
- id: log-e065
- message: "DEBUG: In Split ${body}"
- - setVariable:
- id: setVariable-ec67
- description: Set filename to variable
- name: route:fileName
- expression:
- simple:
- id: simple-9603
- expression: ${body}
- - log:
- id: log-2262
- message: "FileName: ${variable:route:fileName}"
- - pollEnrich:
- id: pollEnrich-6d72
- expression:
- simple:
- id: simple-8d52
- expression: >-
-
sftp://{{sftp.username}}@{{sftp.server}}?password={{sftp.password}}&useList=false&noop=true&fileName=${body}&idempotent=false&bridgeErrorHandler=true
- - choice:
- id: choice-2ba9
- when:
- - id: when-731b
- expression:
- simple:
- id: simple-a35c
- expression: ${variable:route:fileName} == 'staff.csv'
- steps:
- - unmarshal:
- id: unmarshal-59b8
- csv:
- id: csv-4db5
- skipHeaderRecord: true
- - split:
- id: split-5b89
- expression:
- simple:
- id: simple-cb64
- expression: ${body}
- steps:
- - log:
- id: log-5917
- disabled: true
- message: Unmarshal ${body}
- - setBody:
- id: setBody-d554
- expression:
- groovy:
- id: groovy-312e
- expression: "def staffRecord =
body\r\n\r\nreturn[\r\n SchoolId: staffRecord[0],\r\n StaffId:
staffRecord[1],\r\n Title: staffRecord[2],\r\n FirstName:
staffRecord[3],\r\n LastName: staffRecord[4],\r\n Email:
staffRecord[5],\r\n Mobile: staffRecord[6]\r\n]"
- - to:
- id: to-a724
- uri: direct
- parameters:
- name: merge-staff
- - log:
- id: log-e563
- message: "New Body: ${body}"
- - marshal:
- id: marshal-23f4
- csv:
- id: csv-eef3
- header:
- - school_id
- - staff_id
- - title
- - first_name
- - last_name
- - email
- - mobile
- quote: "\""
- quoteMode: ALL
- otherwise:
- id: otherwise-d79e
- - convertBodyTo:
- id: convertBodyTo-5b1c
- description: Convert Body To String
- type: String
- - to:
- id: to-3d61
- description: Send Roster files to test SFTP
- disabled: true
- uri: kamelet:sftp-sink
- parameters:
- password: "{{pssftp.password}}"
- directoryName: .
- username: "{{pssftp.username}}"
- connectionHost: "{{pssftp.server}}"
- connectionPort: "22"
- - to:
- id: to-2811
- description: Send to test ftp
- uri: kamelet:sftp-sink
- parameters:
- connectionHost: upload.gg4l.com
- connectionPort: 22
- username: lexgoogleidm
- password: G7OGR^-J.EOvBq!T
- directoryName: .
- - log:
- id: log-339c
- message: "DONE: ${body}"
- - log:
- id: log-2c52
- message: Roster transfer done at ${date:now:yyyyMMdd hh:mm:ss}
- - setBody:
- id: setBody-3421
- expression:
- simple:
- id: simple-565b
- expression: >-
- SUCCESS: BPS - Roster Files sent at ${date:now:yyyyMMdd
- hh:mm:ss}
- - to:
- id: to-5da4
- description: Send success note to Slack channel
- disabled: true
- uri: slack
- parameters:
- webhookUrl: "{{slack.webhook}}"
- channel: "{{slack.channel}}"
- routeConfiguration:
errorHandler:
id: errorHandler-1b09
