Method: TableSync::BatchPublisher#publish_now

Defined in:
lib/table_sync/batch_publisher.rb

#publish_now ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/table_sync/batch_publisher.rb', line 21

def publish_now
  return unless need_publish?
  Rabbit.publish(params)

  model_naming = TableSync.orm.model_naming(object_class)
  TableSync::Instrument.notify table: model_naming.table, schema: model_naming.schema,
                               event: event,
                               count: publishing_data[:attributes].size, direction: :publish
end