RES
thx for reply. list of servers would be very useful.
it is a loop over tuples of hosts and ports, instead connecting to one host+port.
Hi @pedrokiefer , thank for your reply. * retry forever on one server -> should be customizable -1, .., n == infinite to N * failover -> yes, it sounds...
when implementing `failover` be aware of following behaviour with ActiveMQ in *cluster* mode: * connections are only acceptable to the master * when connection to a slave, the connection is...
@barrust thanks for reply. I am not sure, what kind of license is it - kind of hard to find out on their homepage. But the if the license is...
@1st1 in case you log to stdout from different loggers, where both use stdout as stream handler.
@1st1 Thx. I do fully agree regarding `os.dup()` - it can be even a good workaround for the library mentioned above. But there might be other scenarios (which I am...
hi, would be `concurrent.futures import ProcessPoolExecutor` a workaround?
@1st1 thanks for reply. So the fix would be at the moment to make subprocess async -> run subprocess in thread (with some async flavour). `would be concurrent.futures import ProcessPoolExecutor...
@1st1 here is possible fix ```python def run_subprocess(cmd, loop=None): loop = loop or asyncio.get_event_loop() try: process = await asyncio.create_subprocess_shell(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE) except NotImplementedError: with subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True) as process:...