(url: string)
| 1343 | } |
| 1344 | |
| 1345 | setRemoteIngressUrl(url: string): void { |
| 1346 | this.remoteIngressUrl = url |
| 1347 | logForDebugging(`Remote persistence enabled with URL: ${url}`) |
| 1348 | if (url) { |
| 1349 | // If using CCR, don't delay messages by any more than 10ms. |
| 1350 | this.FLUSH_INTERVAL_MS = REMOTE_FLUSH_INTERVAL_MS |
| 1351 | } |
| 1352 | } |
| 1353 | |
| 1354 | setInternalEventWriter(writer: InternalEventWriter): void { |
| 1355 | this.internalEventWriter = writer |
no test coverage detected