홈>
사용자 정의
GraphStageLogic
를 사용하여 구현 된 노드 네트워크가 있습니다.
. 스테이지에서 예외가 발생하는시기를 판별하는 API를 찾을 수 없습니다 (예 :
IllegalArgumentException
)
Cannot pull port
를 위해
). Akka가하는 유일한 일은 다운 스트림 연결에 실패하는 것입니다. 내가 결정해야 할 것은 예를 들어
postStop
입니다.
또는 런타임 예외로 인해 노드가 종료 될 때 콜백을 통해 해당 정보를
Promise
에 전파
전체 시스템의 상태를 모니터링합니다.
withAttributes(supervisionStrategy)
사용
아무 효과도 없습니다.
GraphStageLogic
내부에서 발생한 예외를 모니터링 할 수있는 방법이 없다는 것이 당황스럽게 보입니다.
?
failStage
기본적으로
GraphStageLogic
의 전체 API와 같이 최종적입니다.
.
- 답변 # 1
관련 자료
- reflection - 스칼라에서 클래스 객체가 특성을 구현하는지 확인하는 방법
- junit - Java 스트림 내에서 when ()을 사용하여 모의를 초기화 할 수 있습니까?
- Emacs가 X11을 지원하는지 프로그래밍 방식으로 결정
- Set의 Object 내부의 Object를 Map으로 변환하는 Java 8 Stream
- c++ - cudaErrorIllegalAddress가 목적지 주소인지 소스 주소인지 확인하는 방법은 무엇입니까?
- node.js - stream () 내부에 요소가 배열로 푸시되지 않습니다
- java - 단일 스트림 내에서 분할 및 필터를 만들 수 있습니까?
- javascript - 변수가 드롭 다운 상자에서 선택한 옵션과 일치하는지 확인하려고합니다 어떻게해야합니까?
- 파이썬 모듈/파일을 가져 오거나 독립형으로 호출했는지 여부를 결정하는 방법은 무엇입니까?
- reflection - Java에서 소스 코드에 '@Override'주석이 있는지 프로그래밍 방식으로 결정하는 방법은 무엇입니까?
- python 3.x - 장고 - 필터 조건 내에서 날짜가 만료되었는지 확인하는 방법
- java - JLabel 텍스트가 잘리는 지 확인
- scala - Flink의 스트림 맵 내에서 동시 맵 업데이트
- Spring AOP - 봄 aop - 메서드가 @scheduled에 의해 호출되었는지 확인
- c++ - 파일 열기, 존재하지 않는 경우 생성 여부 생성 여부 결정
- java - Docker 컨테이너 내에서만 XmlDecoder 및 Akka Stream 문제
- c# - 세포가 반지름 안에 있는지 확인하는 피타고라스 정리
- SQL 열 내의 모든 값이 동일한 지 확인하는 방법은 무엇입니까?
- SQL groupy by 내의 모든 값이 다른지 확인한 다음 모두 반환하는 방법은 무엇입니까?
- foreach - var가있는 for each 루프를 Java Stream으로 변환 하시겠습니까?
관련 질문
- scala : Akka 스트림-파티션을 사용한 병렬 처리
- akka - 임계 값으로 다시 시작
- akka - 배압이 발생할 때 rabbitmq에서 생산자에 대한 고장 콜백 받기
- scala - Akka 스트림을 사용하여 반복기에서 소스 스트림을 만들 때 정리하는 방법은 무엇입니까?
- scala - 파일 변경시 스트림 업데이트
- scala - 동일한 스트림에 존재하는 키를 사용하여 스트림 요소를 어떻게 그룹화합니까?
- akka - 스칼라를 사용하여 TCP 스트림을 읽는 방법
- java - Akka Stream이 스테이지를 서로 강제로 연결
- scala - MergeLatest의 기본값
- scala - Akka 소스가 데이터를 스트리밍하지 않습니까?
그래프를 구체화하는 데 사용되는 ActorMaterializer를 정의 할 때 디 사이더를 사용하면 작동합니다 :
결정자가 전형적인 곳