(url: string)
| 1425 | } |
| 1426 | |
| 1427 | setRemoteIngressUrl(url: string): void { |
| 1428 | this.remoteIngressUrl = url |
| 1429 | logForDebugging(`Remote persistence enabled with URL: ${url}`) |
| 1430 | if (url) { |
| 1431 | // If using CCR, don't delay messages by any more than 10ms. |
| 1432 | this.FLUSH_INTERVAL_MS = REMOTE_FLUSH_INTERVAL_MS |
| 1433 | } |
| 1434 | } |
| 1435 | |
| 1436 | setInternalEventWriter(writer: InternalEventWriter): void { |
| 1437 | this.internalEventWriter = writer |
no test coverage detected