Skip to content

Commit 8fc929b

Browse files
committed
minor refactor
1 parent e74643e commit 8fc929b

File tree

1 file changed

+5
-15
lines changed

1 file changed

+5
-15
lines changed

src/main/java/io/cryostat/recordings/JvmIdHelper.java

+5-15
Original file line numberDiff line numberDiff line change
@@ -118,27 +118,17 @@ public class JvmIdHelper extends AbstractEventEmitter<JvmIdHelper.IdEvent, Strin
118118
this.reverse = new HashMap<>();
119119
}
120120

121-
private boolean observe(ServiceRef sr) {
122-
logger.info("Observing new target: {}", sr);
123-
if (StringUtils.isBlank(sr.getJvmId())) {
124-
return false;
125-
}
126-
reverse.put(sr.getJvmId(), sr);
127-
ids.put(sr.getServiceUri().toString(), CompletableFuture.completedFuture(sr.getJvmId()));
128-
return true;
129-
}
130-
131121
// Use dao directly since refs resolve before listDiscoverableServices is populated
132122
public ServiceRef resolveId(ServiceRef sr) throws JvmIdGetException {
133-
if (observe(sr)) {
123+
logger.info("Observing new target: {}", sr);
124+
String jvmId = sr.getJvmId();
125+
if (StringUtils.isNotBlank(jvmId)) {
134126
return sr;
135127
}
136128
URI serviceUri = sr.getServiceUri();
137129
String uriStr = serviceUri.toString();
138-
if (sr.getJvmId() != null) {
139-
reverse.put(sr.getJvmId(), sr);
140-
return sr;
141-
}
130+
ids.put(uriStr, CompletableFuture.completedFuture(jvmId));
131+
reverse.put(jvmId, sr);
142132
try {
143133
CompletableFuture<String> future =
144134
this.targetConnectionManager.executeConnectedTaskAsync(

0 commit comments

Comments
 (0)