Skip to content

Commit ede0601

Browse files
committed
Merge branch 'position-store-location'
2 parents 59b33f9 + b417ecd commit ede0601

File tree

2 files changed

+17
-0
lines changed

2 files changed

+17
-0
lines changed

lib/consumer/postgres/position_store.rb

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,10 @@ def configure
2929
Messaging::Postgres::Write.configure(self, session: session)
3030
end
3131

32+
def location
33+
stream_name
34+
end
35+
3236
def get
3337
message_data = read.(stream_name)
3438

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -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+
end
12+
end
13+
end

0 commit comments

Comments
 (0)