Skip to content

Latest commit

 

History

History
82 lines (49 loc) · 1.76 KB

README.md

File metadata and controls

82 lines (49 loc) · 1.76 KB

Environment Variables

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

Curl Request(s)

In grails web console:

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()
}