(url: string)
| 1380 | } |
| 1381 | |
| 1382 | setRemoteIngressUrl(url: string): void { |
| 1383 | this.remoteIngressUrl = url |
| 1384 | logForDebugging(`Remote persistence enabled with URL: ${url}`) |
| 1385 | if (url) { |
| 1386 | // If using CCR, don't delay messages by any more than 10ms. |
| 1387 | this.FLUSH_INTERVAL_MS = REMOTE_FLUSH_INTERVAL_MS |
| 1388 | } |
| 1389 | } |
| 1390 | |
| 1391 | setInternalEventWriter(writer: InternalEventWriter): void { |
| 1392 | this.internalEventWriter = writer |
no test coverage detected