Method: ActiveProjection::EventClient#replay_done?

Defined in:
lib/active_projection/event_client.rb

#replay_done?(body) ⇒ Boolean

Returns:

  • (Boolean) 


56
57
58
59
60
61
62
63
 
# File 'lib/active_projection/event_client.rb', line 56

def replay_done?(body)
  if 'replay_done' == body
    LOGGER.debug 'Projections should be up to date now'
    replay_queue.unbind(resend_exchange)
    return true
  end
  false
end