This fixes javadoc warnings, addsa tiny bit of documentation
and corrects logging during recovery.
Change-Id: I13076ec052febb801a08c05adb7d8affca1fea82
Signed-off-by: Robert Varga <rovarga@cisco.com>
/**
* Return an {@link ActorRef} of this ClientActor.
*
/**
* Return an {@link ActorRef} of this ClientActor.
*
+ * @return Actor associated with this behavior
*/
public final @Nonnull ActorRef self() {
return context.self();
*/
public final @Nonnull ActorRef self() {
return context.self();
import org.slf4j.LoggerFactory;
/**
import org.slf4j.LoggerFactory;
/**
- * @param <T> Frontend type
+ * Transient behavior handling messages during initial actor recovery.
*
* @author Robert Varga
*/
*
* @author Robert Varga
*/
final ClientIdentifier nextId;
if (lastId != null) {
if (!currentFrontend.equals(lastId.getFrontendId())) {
final ClientIdentifier nextId;
if (lastId != null) {
if (!currentFrontend.equals(lastId.getFrontendId())) {
- LOG.error("Mismatched frontend identifier, shutting down. Current: {} Saved: {}", currentFrontend,
- lastId.getFrontendId());
+ LOG.error("{}: Mismatched frontend identifier, shutting down. Current: {} Saved: {}",
+ persistenceId(), currentFrontend, lastId.getFrontendId());
return new SavingClientActorBehavior(context(), nextId);
} else if (recover instanceof SnapshotOffer) {
lastId = (ClientIdentifier) ((SnapshotOffer)recover).snapshot();
return new SavingClientActorBehavior(context(), nextId);
} else if (recover instanceof SnapshotOffer) {
lastId = (ClientIdentifier) ((SnapshotOffer)recover).snapshot();
- LOG.debug("{}: recovered identifier {}", lastId);
+ LOG.debug("{}: recovered identifier {}", persistenceId(), lastId);
- LOG.warn("{}: ignoring recovery message {}", recover);
+ LOG.warn("{}: ignoring recovery message {}", persistenceId(), recover);
import org.slf4j.LoggerFactory;
/**
import org.slf4j.LoggerFactory;
/**
+ * Transient behavior handling messages while the new generation is being persisted.
+ *
* @author Robert Varga
*/
final class SavingClientActorBehavior extends RecoveredClientActorBehavior<InitialClientActorContext> {
* @author Robert Varga
*/
final class SavingClientActorBehavior extends RecoveredClientActorBehavior<InitialClientActorContext> {