Skip to content

Commit 04d2ac0

Browse files
committed
FEATURE: Add publish_queue_in_memory option to distributed cache manager.
This is a partial revert of e91d414. Instead of changing the default behavior of what `MessageBus::DistributedCache::Manager#publish` should do when it is called on a Readonly redis, this commit introduces an option to change the behavior.
1 parent 2d6a148 commit 04d2ac0

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

lib/message_bus/distributed_cache.rb

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,11 +16,12 @@ class Manager
1616

1717
attr_accessor :app_version
1818

19-
def initialize(message_bus = nil)
19+
def initialize(message_bus = nil, publish_queue_in_memory: true)
2020
@subscribers = []
2121
@subscribed = false
2222
@lock = Mutex.new
2323
@message_bus = message_bus || MessageBus
24+
@publish_queue_in_memory = publish_queue_in_memory
2425
end
2526

2627
def subscribers
@@ -75,7 +76,11 @@ def publish(hash, message)
7576
message[:origin] = hash.identity
7677
message[:hash_key] = hash.key
7778
message[:app_version] = @app_version if @app_version
78-
@message_bus.publish(CHANNEL_NAME, message, user_ids: [-1], queue_in_memory: false)
79+
80+
@message_bus.publish(CHANNEL_NAME, message,
81+
user_ids: [-1],
82+
queue_in_memory: @publish_queue_in_memory
83+
)
7984
end
8085

8186
def set(hash, key, value)

0 commit comments

Comments
 (0)