MZBench MQTT Broadcast Scenario

broadcast.bdl

#!benchDL
make_install(git = "https://github.com/erlio/vmq_mzbench.git",
             branch = "master")

pool(size = numvar("connections"),
     worker_type = mqtt_worker,
     worker_start = linear(numvar("rate") rps)):

            connect(host = var("sub_node"),
                    client = fixed_client_id("subscriber_pool0_1", worker_id()),
                    clean_session = true,
                    keepalive_interval = 60,
                    proto_version = 3,
                    reconnect_timeout = 4,
                    port = 1883
                    )
            wait(10 sec)
        
            subscribe("b/loadtest", 0)
    
            wait(1 sec)
            set_signal(subscribed, 1)
            wait(10 sec)
            
            wait_signal(subscribed, numvar("connections"))
            wait(numvar("duration") min)
            disconnect()
            wait(10 sec)


pool(size = 1,
     worker_type = mqtt_worker):

            connect(host = var("pub_node"),
                    client = fixed_client_id("publisher_pool0_1", worker_id()),
                    clean_session = true,
                    keepalive_interval = 60,
                    proto_version = 3,
                    reconnect_timeout = 4,
                    port = 1883 
                    )

            wait(1 sec)
            wait_signal(subscribed, numvar("connections"))
            wait(1 sec)
            
            dump("Starting Publish")

            loop(time = numvar("duration") min, rate = 1 rps, iterator = "i"):
                publish("b/loadtest", random_binary(1000), 0)
            
            wait(1 sec)
            disconnect()
            wait(10 sec)