class SalesforceStreamer::ReplayIdErrorExtension
Constants
- REPLAY_ERROR_REGEX
Public Instance Methods
incoming(message, callback)
click to toggle source
# File lib/salesforce_streamer/replay_id_error_extension.rb, line 5 def incoming(message, callback) if message['error']&.match?(REPLAY_ERROR_REGEX) fail ReplayIdError, message['error'] end callback.call message end