Note support of multiple clustered messaging brokers with comma delimited AMQ_HOST (IP address or hostname)
export API_SERVER_ADDRESS=localhost
export API_SERVER_PORT=8080
export ADMIN_SERVER_PORT=9080
export API_REST_SERVER_PROTOCOL=http
export AMQ_CONNECTION_LIST=tcp://localhost:61616
export AMQ_USER=mquser
export AMQ_PASS=mqpass
export ENABLE_CONSUMER_PRODCER_TEST=false
export ENABLE_BENCHMARK_TEST=true
export BENCHMARK_THREADS=10
export BENCHMARK_TOTAL_MSGS=10000
export ENABLE_REQUEST_REPLY_TEST=true
http://localhost:9080/console#new
MAKE SURE TO CLEAR THE QUEUE
kick off the load:
com.microservice.routes.ProducerConsumerRouteBuilder.producerBatchSize = 100
synchronized(com.microservice.ProducerConsumerService?.inflightInstances) {
com.microservice.ProducerConsumerService?.inflightInstances?.size()
}
monitor:
synchronized(com.microservice.ProducerConsumerService?.inflightInstances) {
com.microservice.ProducerConsumerService?.inflightInstances?.size()
}
ramp down:
com.microservice.routes.ProducerConsumerRouteBuilder.producerBatchSize = 0
synchronized(com.microservice.ProducerConsumerService?.inflightInstances) {
com.microservice.ProducerConsumerService?.inflightInstances?.size()
}
MUST WAIT UNTIL PROCESSING FINISHED
list the unresolved messages:
com.microservice.routes.ProducerConsumerRouteBuilder.producerBatchSize = 0
synchronized(com.microservice.ProducerConsumerService?.inflightInstances) {
println "${com.microservice.ProducerConsumerService?.inflightInstances?.toString()}"
com.microservice.ProducerConsumerService?.inflightInstances?.size()
}