Skip to content

Commit e38bb52

Browse files
committed
add catch for subscribe
1 parent 0812b8b commit e38bb52

1 file changed

Lines changed: 13 additions & 8 deletions

File tree

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/filter/inner/ServerRestArgsFilter.java

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -126,14 +126,19 @@ public void onSubscribe(Subscription s) {
126126

127127
@Override
128128
public void onNext(Object o) {
129-
writeResponse(responseEx, produceProcessor, o, response).whenComplete((r, e) -> {
130-
if (e != null) {
131-
subscription.cancel();
132-
result.completeExceptionally(e);
133-
return;
134-
}
135-
subscription.request(1);
136-
});
129+
try {
130+
writeResponse(responseEx, produceProcessor, o, response).whenComplete((r, e) -> {
131+
if (e != null) {
132+
subscription.cancel();
133+
result.completeExceptionally(e);
134+
return;
135+
}
136+
subscription.request(1);
137+
});
138+
} catch (Exception e) {
139+
LOGGER.warn("Failed to subscribe event: {}", o, e);
140+
result.completeExceptionally(e);
141+
}
137142
}
138143

139144
@Override

0 commit comments

Comments
 (0)