| # Licensed to the Apache Software Foundation (ASF) under one or more contributor |
| # license agreements; and to You under the Apache License, Version 2.0. |
| |
| packages: |
| data-processing-with-messagehub: |
| dependencies: |
| wskdeployMessageHub: |
| location: /whisk.system/messaging |
| inputs: |
| user: $MESSAGEHUB_USER |
| password: $MESSAGEHUB_PASSWORD |
| kafka_admin_url: $MESSAGEHUB_ADMIN_HOST |
| kafka_brokers_sasl: $KAFKA_BROKERS_SASL |
| topic: $SOURCE_TOPIC |
| actions: |
| receive-messages-from-messagehub: |
| function: src/receive-messages.js |
| runtime: nodejs:6 |
| process-messages-received-from-messagehub: |
| function: src/process-messages.js |
| runtime: nodejs:6 |
| sequences: |
| data-processing-sequence: |
| actions: receive-messages-from-messagehub, process-messages-received-from-messagehub |
| triggers: |
| wskdeployIntegrationTestMessageHubTrigger: |
| feed: wskdeployMessageHub/messageHubFeed |
| rules: |
| data-processing-rule: |
| trigger: wskdeployIntegrationTestMessageHubTrigger |
| action: data-processing-sequence |
