You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jan 13, 2023. It is now read-only.
Currently, if I specify the Rabbit Host Parts via topology config, I get a a NPE when it is trying to configure the connection. It looks up HA Hosts and fails because it is null (not specified). If I use "" for Hosts, it fails again trying to use the value as a host. The Config.getFromMap() needs to check for null before trying .toString().
I fixed this in a pull request.
The text was updated successfully, but these errors were encountered:
Same issue. It is currently not possible to configure it via the topology config unless you define rabbitmq.ha.hosts, see [https://github.com/ppat/storm-rabbitmq/blob/master/src/main/java/io/latent/storm/rabbitmq/config/ConnectionConfig.java#L176]
Any reason not to fix it?
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
Currently, if I specify the Rabbit Host Parts via topology config, I get a a NPE when it is trying to configure the connection. It looks up HA Hosts and fails because it is null (not specified). If I use
""
for Hosts, it fails again trying to use the value as a host. The Config.getFromMap() needs to check for null before trying.toString()
.I fixed this in a pull request.
The text was updated successfully, but these errors were encountered: