add prefix so keys stop clashing
This commit is contained in:
parent
d3f911cc4c
commit
edaa7643c5
|
@ -68,19 +68,19 @@ class MessageBus::ReliablePubSub
|
||||||
end
|
end
|
||||||
|
|
||||||
def backlog_key(channel)
|
def backlog_key(channel)
|
||||||
"__mb_backlog_#{channel}"
|
"__mb_backlog_n_#{channel}"
|
||||||
end
|
end
|
||||||
|
|
||||||
def backlog_id_key(channel)
|
def backlog_id_key(channel)
|
||||||
"__mb_backlog_id_#{channel}"
|
"__mb_backlog_id_n_#{channel}"
|
||||||
end
|
end
|
||||||
|
|
||||||
def global_id_key
|
def global_id_key
|
||||||
"__mb_global_id"
|
"__mb_global_id_n"
|
||||||
end
|
end
|
||||||
|
|
||||||
def global_backlog_key
|
def global_backlog_key
|
||||||
"__mb_global_backlog"
|
"__mb_global_backlog_n"
|
||||||
end
|
end
|
||||||
|
|
||||||
# use with extreme care, will nuke all of the data
|
# use with extreme care, will nuke all of the data
|
||||||
|
|
Loading…
Reference in New Issue