#!/bin/sh
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.
#

# This starts the controller for coordinating perf tests/

. check-qpid-java-env

PROGRAM_NAME="start-consumers"
PROCESS_COUNT=1
CON_COUNT=1
MSG_COUNT=10000
ADDRESS="queue;{create:always}"
UNIQUE_DEST="false"

EXTRA_JVM_ARGS=" -Dmax_prefetch=500 "

TEST_ID=`echo ${HOSTNAME} |  awk -F . '{print $1}'`

TEMP=$(getopt -n $PROGRAM_NAME -o C:P:uc:p:a:s:t:w:h\
 --long connection-count:,process-count:,create-unique-queues-topics,\
jvm-args:,queue:,topic:,address:,\
msg-count:,help -- "$@")                                                            

usage()
{
  printf "\n%s\n" "Usage: start-producers [option].."

  printf "\n%32s\n%51s\n"  "-C, --connection-count=count" "No of consumers participating in the test"

  printf "\n%29s\n%51s\n"  "-P, --process-count=count" "No of producers participating in the test"

  printf "\n%37s\n%105s\n"  "-u, --create-unique-queues-topics" "This will create unique queue names and topics based on what you specify for --queue or --topic"

  printf "\n%11s\n%55s\n"  "--queue" "The Queue you want to publish to. Ex my-queue"

  printf "\n%11s\n%84s\n"  "--topic" "The Topic you want to publish to in amq.topic exchange. Ex amq.topic/topic"

  printf "\n%13s\n%44s\n"  "--address" "The address you want to publish to"

  printf "\n%25s\n%50s\n"  "-c, --msg-count=count" "message count per test (default 500,000)"

  printf "\n%18s\n%49s\n"  "-a, --jvm-args" "Extra jvm arguments you want to specify"
}

eval set -- "$TEMP"
while true; do     
        case $1 in 
                -C|--connection-count)
                        CON_COUNT="$2"; shift; shift; continue
                ;;                                    
                -P|--process-count)                            
                        PROCESS_COUNT="$2"; shift; shift; continue  
                ;;
		-u|--create-unique-queues-topics)                            
                        UNIQUE_DEST="true"; shift; continue  
                ;;                                     
                --queue)                            
                        ADDRESS="$2;{create: always}"; shift; shift; continue  
                ;;                                    
                --topic)                            
                        ADDRESS="amq.topic/$2"; shift; shift; continue  
                ;;                                    
                --address)                            
                        ADDRESS="$2"; shift; shift; continue  
                ;;                                 
                -h|--help)                            
                        usage                         
                        exit 0                        
                ;;                                    
                -a|--jvm-args)               
                        EXTRA_JVM_ARGS="$2"; shift; shift; continue 
                ;;   
                -c|--msg-count)               
                        MSG_COUNT="$2"; shift; shift; continue 
                ;;                                                                  
                --)                                                                 
                        # no more arguments to parse                                
                        break                                                       
                ;;                                                                  
                *)       
                        # no more arguments to parse                                                                                            
                        break                                                      
                ;;                                                                  
        esac                                                                        
done     

CONSUMER_ARGS="-server -Durl=amqp://guest:guest@clientid/testpath?brokerlist='tcp://localhost:5672' -Dprecision=mili -Dcon_count=$CON_COUNT -Dprint_std_dev=true"

start_consumers()
{
  for ((i=0; i<$PROCESS_COUNT; i++))
  do
     if [ "$UNIQUE_DEST" = "true" ]; then
     	sh run-sub "$CONSUMER_ARGS $@" "${TEST_ID}_$i" > ${TEST_ID}_$i.sub.out 2>&1  &    
     else
        sh run-sub "$CONSUMER_ARGS $@" > ${TEST_ID}_$i.sub.out 2>&1  &    
     fi 
  done
}

start_consumers "-Daddress=$ADDRESS -Duse_unique_dest=$UNIQUE_DEST -Dmsg_count=$MSG_COUNT -Dcon_count=$CON_COUNT $EXTRA_JVM_ARGS"