help me with right setting on rmq

[bookvik]

titanoboa_1 | ERROR [main] - Error starting system :core-rmq !
titanoboa_1 | clojure.lang.ExceptionInfo: Error in component :mq-connection in system com.stuartsierra.component.SystemMap calling #'com.stuartsierra.component/start {:reason :com.stuartsierra.component/component-function-threw-exception, :function #'com.stuartsierra.component/start, :system-key :mq-connection, :component #titanoboa.channel.rmq.RMQConnectionComponent{:params {:host "localhost", :port 5672, :username "guest", :password "guest", :vhost "/", :connection-name "titanoboa-connection"}, :connection nil}, :system #}

I tried to insert the host in different places and systems config and in front of it as it is now in the screenshot.

But I always always get something that the code does not apply my value

although I see that this parameter is present

I will attach the dependency file at the same time

[bookvik]

just assembled a new build where I replaced the host with mine, apparently somewhere there is not enough merge

I will find it if I correct it

[mikub]

@bookvik here it is:
https://github.com/mikub/titanoboa/blob/cluster/src/clj/titanoboa/system/rabbitmq.clj#L21

You can see that under :systems-config -> core-rmq you might need to add following keys:

:mq-host 
:mq-port 
:mq-username 
:mq-password 
:mq-vhost

[bookvik]

i am using the latest version : 1 alpha

I have not yet managed to send the completed tasks on the rabbit to the postgres archive

[mikub]

@bookvik see a sample config for RMQ here:
https://github.com/mikub/titanoboa/wiki/Clustering#server-config-file
i.e. you have to add :archival-queue and make sure it is the same for the archival system:

:systems-catalogue {:core  {:system-def #'titanoboa.system.rabbitmq/distributed-core-system
                                                         :worker-def #'titanoboa.system.rabbitmq/distributed-worker-system
                                                         :autostart  true
                                                         :worker-count 2
                                                         :restart-workers-on-error true}
                                                 :archival-system {:system-def #'titanoboa.system.rabbitmq/archival-system
                                                                   :autostart  true}}

:systems-config {:core {:new-jobs-queue "titanoboa-bus-queue-0"
                                                     :jobs-queue "titanoboa-bus-queue-1"
                                                     :archival-queue "titanoboa-bus-archive"
                                                     :eviction-age (* 1000 60 5)
                                                     :eviction-interval (* 1000 30)}
                                              :archival-system {:jdbc-url "jdbc:postgresql://localhost:5432/mydb?currentSchema=titanoboa"
                                                                :archival-queue "titanoboa-bus-archive"}}

[bookvik]

thank you. I'll try to do it today

[bookvik]

awesome! it is worked perfectly

[mikub]

Answered in these two comments:

#38 (reply in thread)

#38 (reply in thread)