lib/table_sync/publisher.rb in table_sync-1.11.0 vs lib/table_sync/publisher.rb in table_sync-1.12.0
- old
+ new
@@ -32,10 +32,11 @@
def publish_now
# Update request and object does not exist -> skip publishing
return if !object && !destroyed?
Rabbit.publish(params)
- TableSync::Instrument.notify table: TableSync.orm.table_name(object_class),
+ model_naming = TableSync.orm.model_naming(object_class)
+ TableSync::Instrument.notify table: model_naming.table, schema: model_naming.schema,
event: event, direction: :publish
end
private