Doc Polishing
- throw exceptions when publisher confirms fail Resolves #316
This commit is contained in:
committed by
Oleg Zhurakousky
parent
c5690a776e
commit
8c9cb784c1
@@ -956,18 +956,17 @@ public class Application {
|
||||
if (correlation.getReturnedMessage() != null) {
|
||||
log.error("Message for " + correlation.getPayload() + " was returned ");
|
||||
|
||||
// try to re-publish, send a DLQ, etc
|
||||
// throw some exception to invoke binder retry/error handling
|
||||
|
||||
}
|
||||
}
|
||||
catch (InterruptedException e) {
|
||||
Thread.currentThread().interrupt();
|
||||
e.printStackTrace();
|
||||
throw new IllegalStateException(e);
|
||||
}
|
||||
catch (ExecutionException | TimeoutException e) {
|
||||
e.printStackTrace();
|
||||
throw new IllegalStateException(e);
|
||||
}
|
||||
});
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user