Skip to content

Commit e8a5a9b

Browse files
committed
Vestigial allowances of position stream for an entity stream are removed
1 parent 2697e66 commit e8a5a9b

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

lib/consumer/postgres/position_store/stream_name.rb

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ def self.position_stream_name(stream_name, consumer_identifier: nil)
99
raise Error, "Position store's stream name must be a category (Stream Name: #{stream_name})"
1010
end
1111

12-
stream_id = MessageStore::StreamName.get_id(stream_name)
1312
entity_name = MessageStore::StreamName.get_entity_name(stream_name)
1413
type_list = MessageStore::StreamName.get_types(stream_name)
1514

@@ -19,12 +18,9 @@ def self.position_stream_name(stream_name, consumer_identifier: nil)
1918
type_list << position_type
2019
end
2120

21+
stream_id = nil
2222
if not consumer_identifier.nil?
23-
if stream_id.nil?
24-
stream_id = consumer_identifier
25-
else
26-
stream_id = "#{stream_id}-#{consumer_identifier}"
27-
end
23+
stream_id = consumer_identifier
2824
end
2925

3026
MessageStore::StreamName.stream_name(

0 commit comments

Comments
 (0)