We are attempting to send a local message to a remote actor,
which seems to be a mixup with data tree presence. Add dataTree
to toString() output so we know which connections resolve to
being local and which to being remote.
Change-Id: If1ed3cfdea24148456a4d310949fb480791c1ffa
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
@Override
public final String toString() {
@Override
public final String toString() {
- return addToStringAttributes(MoreObjects.toStringHelper(this)).toString();
+ return addToStringAttributes(MoreObjects.toStringHelper(this).omitNullValues()).toString();
}
protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
}
protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
if (getIdentifier().equals(req.getTarget())) {
Verify.verify(req instanceof TransactionRequest, "Unhandled request %s", req);
if (getIdentifier().equals(req.getTarget())) {
Verify.verify(req instanceof TransactionRequest, "Unhandled request %s", req);
- LOG.debug("Forwarding queued request{} to successor {}", req, successor);
+ LOG.debug("Forwarding queued request {} to successor {}", req, successor);
successor.handleForwardedRemoteRequest((TransactionRequest<?>) req, e.getCallback());
it.remove();
}
successor.handleForwardedRemoteRequest((TransactionRequest<?>) req, e.getCallback());
it.remove();
}
- void forwardToRemote(final RemoteProxyTransaction successor, final TransactionRequest<?> request,
+ final void forwardToRemote(final RemoteProxyTransaction successor, final TransactionRequest<?> request,
final Consumer<Response<?, ?>> callback) {
if (request instanceof CommitLocalTransactionRequest) {
final CommitLocalTransactionRequest req = (CommitLocalTransactionRequest) request;
final Consumer<Response<?, ?>> callback) {
if (request instanceof CommitLocalTransactionRequest) {
final CommitLocalTransactionRequest req = (CommitLocalTransactionRequest) request;
@Override
protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
@Override
protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
- return super.addToStringAttributes(toStringHelper).add("cookie", cookie).add("shard", shardName);
+ return super.addToStringAttributes(toStringHelper).add("cookie", cookie).add("shard", shardName)
+ .add("dataTree", dataTree.orElse(null));