Skip to content
GitLab
Menu
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
desktop_robotti
drobotti-processing-and-control
Commits
928c4d6e
Commit
928c4d6e
authored
Nov 29, 2021
by
Gill Lumer-Klabbers
Browse files
Docker for two-way rmq confirmed working
parent
2822d3ad
Changes
3
Hide whitespace changes
Inline
Side-by-side
docker/rmq.yml
0 → 100644
View file @
928c4d6e
version
:
'
3'
services
:
rmq_server
:
container_name
:
rmq-srv
build
:
context
:
../
dockerfile
:
./docker/rmq-server/rmq_server.Dockerfile
restart
:
always
network_mode
:
bridge
ports
:
-
5672:5672
-
15672:15672
-
1883:1883
rmq_publisher
:
container_name
:
rmq-pub
build
:
context
:
../
dockerfile
:
./docker/rmq-publisher/rmq_publisher.Dockerfile
depends_on
:
-
rmq_server
restart
:
always
network_mode
:
bridge
rmq_subscriber
:
container_name
:
rmq-sub
build
:
context
:
../
dockerfile
:
./docker/rmq-subscriber/rmq_subscriber.Dockerfile
depends_on
:
-
rmq_server
restart
:
always
network_mode
:
bridge
src/rmq_bridge/rmq_bridge/rmq_publisher.py
View file @
928c4d6e
...
...
@@ -117,7 +117,7 @@ class RabbitMQPublisher(Node):
def
init_rabbitmq
(
self
):
self
.
get_logger
().
info
(
"Initializing Connection"
)
time
.
sle
time
.
sle
ep
(
3
)
for
i
in
range
(
5
):
try
:
self
.
rmq_connection
=
pika
.
BlockingConnection
(
...
...
@@ -147,7 +147,7 @@ class RabbitMQPublisher(Node):
except
Exception
as
err
:
if
i
==
0
:
self
.
get_logger
().
info
(
"RabbitMQ Initialization failed. Is rabbitmq running?"
)
self
.
get_logger
().
info
(
err
)
self
.
get_logger
().
info
(
str
(
err
)
)
self
.
get_logger
().
info
(
f
"Retrying... (try
{
i
+
1
}
out of 5)"
)
time
.
sleep
(
1
)
else
:
...
...
src/rmq_bridge/rmq_bridge/rmq_subscriber.py
View file @
928c4d6e
...
...
@@ -102,7 +102,7 @@ class RabbitMQSubscriber(Node):
except
Exception
as
err
:
if
i
==
0
:
self
.
get_logger
().
info
(
"RabbitMQ Initialization failed. Is rabbitmq running?"
)
self
.
get_logger
().
info
(
err
)
self
.
get_logger
().
info
(
str
(
err
)
)
self
.
get_logger
().
info
(
f
"Retrying... (try
{
i
+
1
}
out of 5)"
)
time
.
sleep
(
1
)
else
:
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment