| | |
|---|
| | | try |
|---|
| | | { |
|---|
| | | registry.synchronize(toRuntimeConfig(adapter)); |
|---|
| | | AdapterDiscoveryResult result = persistence.discover(registry, new DiscoverySource( |
|---|
| | | AdapterDiscoveryResult result = persistence.discoverForReception(registry, new DiscoverySource( |
|---|
| | | adapter.getAdapterCode(), adapter.getAdapterId(), adapter.getAdapterName(), |
|---|
| | | adapter.getPollIntervalMs())); |
|---|
| | | mapper.updateDiscoverySuccess(adapterId, result.observedAtUtc()); |
|---|
| | |
|---|
| | | { |
|---|
| | | Instant lastAttempt = adapter.getLastAttemptAtUtc(); |
|---|
| | | if (lastAttempt != null && Duration.between(lastAttempt, now).toMillis() < adapter.getPollIntervalMs()) continue; |
|---|
| | | try { discover(adapter.getAdapterId()); } |
|---|
| | | try |
|---|
| | | { |
|---|
| | | if (persistence.shouldPollReception(adapter.getAdapterCode())) discover(adapter.getAdapterId()); |
|---|
| | | } |
|---|
| | | catch (ServiceException ignored) { /* 失败状态已持久化，下一轮按周期重试。 */ } |
|---|
| | | } |
|---|
| | | } |
|---|
