flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils/SubscribeReceiver.java [33:45]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.receiverActor = receiverActor;
  }

  public void setReceiverActor(ActorRef receiverActor) {
    this.receiverActor = receiverActor;
  }

  public ActorRef getReceiverActor() {
    return receiverActor;
  }

  @Override
  public boolean equals(Object obj) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils/UnsubscribeReceiver.java [32:45]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.receiverActor = receiverActor;
  }

  public void setReceiverActor(ActorRef receiverActor) {
    this.receiverActor = receiverActor;
  }

  public ActorRef getReceiverActor() {
    return receiverActor;
  }


  @Override
  public boolean equals(Object obj) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -