File tree Expand file tree Collapse file tree
coprocessor/fhevm-engine/host-listener/src/consumer
test-suite/fhevm/scenarios Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -82,7 +82,7 @@ pub async fn run_consumer(config: ConsumerConfig) -> Result<()> {
8282 let broker_url = config. url ; // e.g."amqp://user:pass@localhost:5672";
8383 let broker = Broker :: from_url ( & broker_url) . await ?;
8484 let consumer_id =
85- format ! ( "{}.{}" , "copro-eth-host-consumer" , config. chain_id) ;
85+ format ! ( "{}.{}" , config . service_name , config. chain_id) ;
8686 let client =
8787 ListenerConsumer :: new ( & broker, chain_id. as_u64 ( ) , & consumer_id) ;
8888
Original file line number Diff line number Diff line change @@ -5,3 +5,12 @@ description: Smallest multi-coprocessor consensus setup for drift and quorum tes
55topology :
66 count : 2
77 threshold : 2
8+ instances :
9+ - index : 0
10+ args :
11+ host-listener-consumer :
12+ - --service-name=coprocessor-host-listener-consumer
13+ - index : 1
14+ args :
15+ host-listener-consumer :
16+ - --service-name=coprocessor1-host-listener-consumer
You can’t perform that action at this time.
0 commit comments