diff options
Diffstat (limited to 'src/util/cache/EntityCache.ts')
| -rw-r--r-- | src/util/cache/EntityCache.ts | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/util/cache/EntityCache.ts b/src/util/cache/EntityCache.ts index 9135fef3..ba1e5bd8 100644 --- a/src/util/cache/EntityCache.ts +++ b/src/util/cache/EntityCache.ts @@ -24,7 +24,7 @@ import { } from "typeorm"; import { QueryDeepPartialEntity } from "typeorm/query-builder/QueryPartialEntity"; import { BaseClassWithId } from "../entities/BaseClass"; -import { Config, getDatabase } from "../util"; +import { Config, getDatabase, RabbitMQ } from "../util"; import { CacheManager } from "./Cache"; function getObjectKeysAsArray(obj?: Record<string, any>) { @@ -52,7 +52,9 @@ class BaseEntityCache extends BaseClassWithId { static useDataSource(dataSource: DataSource | null) { super.useDataSource(dataSource); - this.cacheEnabled = Config.get().cache.enabled ?? true; + const isMultiThreaded = + process.env.EVENT_TRANSMISSION === "process" || RabbitMQ.connection; + this.cacheEnabled = Config.get().cache.enabled ?? !isMultiThreaded; if (Config.get().cache.redis) return; // TODO: Redis cache if (!this.cacheEnabled) return; this.cache = new CacheManager(); |