失败不停程序
This commit is contained in:
@@ -62,7 +62,6 @@ public class RtasrClientApp extends AbstractRtasrWebSocketListener{
|
|||||||
public void onFail(WebSocket webSocket, Throwable t, Response response) {
|
public void onFail(WebSocket webSocket, Throwable t, Response response) {
|
||||||
result = AlitaResult.bizError(t.getMessage());
|
result = AlitaResult.bizError(t.getMessage());
|
||||||
latch.countDown();
|
latch.countDown();
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -70,19 +69,16 @@ public class RtasrClientApp extends AbstractRtasrWebSocketListener{
|
|||||||
logger.error("业务异常,返回信息为:{}", text);
|
logger.error("业务异常,返回信息为:{}", text);
|
||||||
result = AlitaResult.bizError(text);
|
result = AlitaResult.bizError(text);
|
||||||
latch.countDown();
|
latch.countDown();
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onClosing(WebSocket webSocket, int code, String reason) {
|
public void onClosing(WebSocket webSocket, int code, String reason) {
|
||||||
latch.countDown();
|
latch.countDown();
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onClosed() {
|
public void onClosed() {
|
||||||
latch.countDown();
|
latch.countDown();
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static AlitaResult<String> execute(InputStream is, String from, XfProperties xfProperties) {
|
public static AlitaResult<String> execute(InputStream is, String from, XfProperties xfProperties) {
|
||||||
|
|||||||
@@ -216,7 +216,6 @@ public class WebIATWS extends WebSocketListener {
|
|||||||
log.info("onFailure body:" + response.body().string());
|
log.info("onFailure body:" + response.body().string());
|
||||||
if (101 != code) {
|
if (101 != code) {
|
||||||
log.info("connection failed");
|
log.info("connection failed");
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
|
|||||||
@@ -137,7 +137,6 @@ public class WebTtsWS extends WebSocketListener {
|
|||||||
log.info("onFailure body:" + response.body().string());
|
log.info("onFailure body:" + response.body().string());
|
||||||
if (101 != code) {
|
if (101 != code) {
|
||||||
log.info("connection failed");
|
log.info("connection failed");
|
||||||
System.exit(0);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
|
|||||||
Reference in New Issue
Block a user