This is an automated email from the ASF dual-hosted git repository. japetrsn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk-package-kafka.git
The following commit(s) were added to refs/heads/master by this push: new 496467e Optionally Install Producer Action (#305) 496467e is described below commit 496467e2930530fc53a3b194c6c8ca73030cd5f1 Author: James Dubee <jwdu...@us.ibm.com> AuthorDate: Fri Nov 9 18:53:52 2018 -0500 Optionally Install Producer Action (#305) * Optionally Install Producer Action * Use Environment Variable --- installCatalog.sh | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/installCatalog.sh b/installCatalog.sh index 855e6be..552619e 100755 --- a/installCatalog.sh +++ b/installCatalog.sh @@ -15,7 +15,7 @@ WSK_CLI="$OPENWHISK_HOME/bin/wsk" if [ $# -eq 0 ] then -echo "Usage: ./installCatalog.sh <authkey> <edgehost> <dburl> <dbprefix> <apihost>" +echo "Usage: ./installCatalog.sh <authkey> <edgehost> <dburl> <dbprefix> <apihost> <workers>" fi AUTH="$1" @@ -24,6 +24,7 @@ DB_URL="$3" DB_NAME="${4}ow_kafka_triggers" APIHOST="$5" WORKERS="$6" +INSTALL_PRODUCE_ACTION=${INSTALL_PRODUCE_ACTION:="true"} # If the auth key file exists, read the key in the file. Otherwise, take the # first argument as the key itself. @@ -105,10 +106,12 @@ $WSK_CLI -i --apihost "$EDGEHOST" action update --kind nodejs:6 messagingWeb/mes -a description 'Write a new trigger to MH provider DB' \ -a parameters '[ {"name":"kafka_brokers_sasl", "required":true, "description": "Array of Message Hub brokers"},{"name":"user", "required":true, "description": "Message Hub username"},{"name":"password", "required":true, "description": "Message Hub password", "type":"password"},{"name":"topic", "required":true, "description": "Topic to subscribe to"},{"name":"isJSONData", "required":false, "description": "Attempt to parse message value as JSON"},{"name":"isBinaryKey", "required":false [...] -$WSK_CLI -i --apihost "$EDGEHOST" action update messaging/messageHubProduce "$PACKAGE_HOME/action/messageHubProduce.py" \ - --auth "$AUTH" \ - --kind python:3 \ - -a deprecated true \ - -a description 'Deprecated - Produce a message to Message Hub' \ - -a parameters '[ {"name":"kafka_brokers_sasl", "required":true, "description": "Array of Message Hub brokers"},{"name":"user", "required":true, "description": "Message Hub username"},{"name":"password", "required":true, "description": "Message Hub password", "type":"password"},{"name":"topic", "required":true, "description": "Topic that you wish to produce a message to"},{"name":"value", "required":true, "description": "The value for the message you want to produce"},{"name":"key", " [...] - -a sampleInput '{"kafka_brokers_sasl":"[\"kafka01-prod01.messagehub.services.us-south.bluemix.net:9093\"]", "username":"someUsername", "password":"somePassword", "topic":"mytopic", "value": "This is my message"}' +if [ $INSTALL_PRODUCE_ACTION == "true" ]; then + $WSK_CLI -i --apihost "$EDGEHOST" action update messaging/messageHubProduce "$PACKAGE_HOME/action/messageHubProduce.py" \ + --auth "$AUTH" \ + --kind python:3 \ + -a deprecated true \ + -a description 'Deprecated - Produce a message to Message Hub' \ + -a parameters '[ {"name":"kafka_brokers_sasl", "required":true, "description": "Array of Message Hub brokers"},{"name":"user", "required":true, "description": "Message Hub username"},{"name":"password", "required":true, "description": "Message Hub password", "type":"password"},{"name":"topic", "required":true, "description": "Topic that you wish to produce a message to"},{"name":"value", "required":true, "description": "The value for the message you want to produce"},{"name":"key", [...] + -a sampleInput '{"kafka_brokers_sasl":"[\"kafka01-prod01.messagehub.services.us-south.bluemix.net:9093\"]", "username":"someUsername", "password":"somePassword", "topic":"mytopic", "value": "This is my message"}' +fi