diff options
| author | Erik Johnston <erik@matrix.org> | 2020-07-16 14:06:28 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-07-16 14:06:28 +0100 |
| commit | 649a7ead5c4bd2d8b7c486ac1a68ce4e41d49767 (patch) | |
| tree | 2a3ee5836578e99c15a8c342934c6e7d056563a2 /synapse/config/push.py | |
| parent | Merge pull request #7866 from matrix-org/rav/fix_guest_user_id (diff) | |
| download | synapse-649a7ead5c4bd2d8b7c486ac1a68ce4e41d49767.tar.xz | |
Add ability to run multiple pusher instances (#7855)
This reuses the same scheme as federation sender sharding
Diffstat (limited to 'synapse/config/push.py')
| -rw-r--r-- | synapse/config/push.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/synapse/config/push.py b/synapse/config/push.py index 6f2b3a7faa..a1f3752c8a 100644 --- a/synapse/config/push.py +++ b/synapse/config/push.py @@ -14,7 +14,7 @@ # See the License for the specific language governing permissions and # limitations under the License. -from ._base import Config +from ._base import Config, ShardedWorkerHandlingConfig class PushConfig(Config): @@ -24,6 +24,9 @@ class PushConfig(Config): push_config = config.get("push", {}) self.push_include_content = push_config.get("include_content", True) + pusher_instances = config.get("pusher_instances") or [] + self.pusher_shard_config = ShardedWorkerHandlingConfig(pusher_instances) + # There was a a 'redact_content' setting but mistakenly read from the # 'email'section'. Check for the flag in the 'push' section, and log, # but do not honour it to avoid nasty surprises when people upgrade. |