We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b06f4bd commit 20b3c43Copy full SHA for 20b3c43
aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/SubscriptionProcessor.java
@@ -150,8 +150,9 @@ synchronized void startSubscriptions() throws DataStoreException {
150
LOG.debug("Waiting for subscriptions to start.");
151
subscriptionsStarted = latch.abortableAwait(adjustedTimeoutSeconds, TimeUnit.SECONDS);
152
} catch (InterruptedException exception) {
153
- LOG.warn("Subscription operations were interrupted during setup.");
154
- return;
+ String errorMessage = "Subscription operations were interrupted during setup.";
+ LOG.warn(errorMessage);
155
+ throw new DataStoreException(errorMessage, "Retry");
156
}
157
158
if (subscriptionsStarted) {
0 commit comments