There was an error while loading. Please reload this page.
1 parent ea22340 commit a233693Copy full SHA for a233693
test/interactive/write_messages_periodically.rb
@@ -2,7 +2,7 @@
2
3
category = ENV['CATEGORY'] || 'testPostgresConsumer'
4
5
-write = MessageStore::Postgres::Write.build
+write = Messaging::Postgres::Write.build
6
7
period = (ENV['PERIOD'] || 300).to_i
8
@@ -11,9 +11,9 @@
11
(1..4).to_a.cycle do |stream_id|
12
stream_name = MessageStore::StreamName.stream_name(category, stream_id)
13
14
- message_data = Controls::MessageData::Write.example
+ message = Controls::Message.example
15
16
- position = write.(message_data, stream_name)
+ position = write.(message, stream_name)
17
18
logger.info "Wrote message (Stream Name: #{stream_name}, Position: #{position})"
19
0 commit comments