diff options
| author | Zach Smith <zach@driver.xyz> | 2018-10-02 16:53:12 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-10-02 16:53:12 -0700 |
| commit | c1b74c39568d6152f1498508f5aaaaf069aba39b (patch) | |
| tree | 2c3fa2560cd109da434262708501a15bc0ae20dc /src/main/scala/xyz/driver/core/messaging/StreamBus.scala | |
| parent | 0783a7767d69b32afb4acf3eb01d541660ea879d (diff) | |
| download | driver-core-1.x.tar.gz driver-core-1.x.tar.bz2 driver-core-1.x.zip | |
* Remove recover from processMessage in StreatBus
* Check if queue exists before creating
Diffstat (limited to 'src/main/scala/xyz/driver/core/messaging/StreamBus.scala')
| -rw-r--r-- | src/main/scala/xyz/driver/core/messaging/StreamBus.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/scala/xyz/driver/core/messaging/StreamBus.scala b/src/main/scala/xyz/driver/core/messaging/StreamBus.scala index a9ba3a7..44d75cd 100644 --- a/src/main/scala/xyz/driver/core/messaging/StreamBus.scala +++ b/src/main/scala/xyz/driver/core/messaging/StreamBus.scala @@ -76,7 +76,7 @@ trait StreamBus extends Bus { maxRestarts ) { () => subscribe(topic, config) - .via(processMessage.recover({ case _ => Nil })) + .via(processMessage) .log(topic.name) .mapConcat(identity) } |