There was an error while loading. Please reload this page.
1 parent 59b33f9 commit b417ecdCopy full SHA for b417ecd
lib/consumer/postgres/position_store.rb
@@ -29,6 +29,10 @@ def configure
29
Messaging::Postgres::Write.configure(self, session: session)
30
end
31
32
+ def location
33
+ stream_name
34
+ end
35
+
36
def get
37
message_data = read.(stream_name)
38
test/automated/position_store/location.rb
@@ -0,0 +1,13 @@
1
+require_relative '../automated_init'
2
3
+context "Position Store" do
4
+ context "Location" do
5
+ stream_name = Controls::StreamName::Position.example
6
7
+ position_store = Consumer::Postgres::PositionStore.new(stream_name)
8
9
+ test "Is the position stream name" do
10
+ assert(position_store.stream_name == stream_name)
11
12
13
+end
0 commit comments