An efford of improving error handling for subscribing. When a message is received we first try to decode the body and then yield to caller to process the message. It is the gem's responsibility not to raise an error or to crash the listener thread. It is the caller's responsibility not to raise an error during the process. If it does happen, the gem should not consume the error. PR #44 already re-raise the error for Kafka events. We now apply the same logic to all other subscribing types.
An efford of improving error handling for subscribing. When a message is received we first try to decode the body and then yield to caller to process the message. It is the gem's responsibility not to raise an error or to crash the listener thread. It is the caller's responsibility not to raise an error during the process. If it does happen, the gem should not consume the error. PR #44 already re-raise the error for Kafka events. We now apply the same logic to all other subscribing types.