aboutsummaryrefslogtreecommitdiffstats
path: root/container-messagebus
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-11-18 20:37:35 +0100
committerJon Bratseth <bratseth@gmail.com>2020-11-18 20:37:35 +0100
commitb01ecd72d26a45ff4b498881446f5e62237c64be (patch)
treec6b4626e262d234900929132e4554b00cda03c49 /container-messagebus
parent804b5ea7d3822847d2b732c79fd35a5eceba15b4 (diff)
Non-functional-changes-only
Diffstat (limited to 'container-messagebus')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/MbusClientProvider.java1
-rw-r--r--container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java23
2 files changed, 8 insertions, 16 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/MbusClientProvider.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/MbusClientProvider.java
index b90f96fb240..2b86d83547e 100644
--- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/MbusClientProvider.java
+++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/MbusClientProvider.java
@@ -61,4 +61,5 @@ public class MbusClientProvider implements Provider<MbusClient> {
public void deconstruct() {
client.release();
}
+
}
diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java
index e62f6a8a21a..68b1f5aa5db 100644
--- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java
+++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java
@@ -159,7 +159,7 @@ public final class SessionCache extends AbstractComponent {
return sourcesCreator.retain(sourceLock, sources, p);
}
- private abstract class SessionCreator<PARAMS, KEY, SESSION extends SharedResource> {
+ private abstract static class SessionCreator<PARAMS, KEY, SESSION extends SharedResource> {
abstract SESSION create(PARAMS p);
@@ -352,6 +352,7 @@ public final class SessionCache extends AbstractComponent {
}
static class UnknownThrottlePolicySignature extends ThrottlePolicySignature {
+
private final ThrottlePolicy policy;
UnknownThrottlePolicySignature(final ThrottlePolicy policy) {
@@ -409,26 +410,16 @@ public final class SessionCache extends AbstractComponent {
@Override
public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
- if (obj == null) {
- return false;
- }
- if (getClass() != obj.getClass()) {
- return false;
- }
+ if (this == obj) return true;
+ if (obj == null) return false;
+ if (getClass() != obj.getClass()) return false;
SourceSessionKey other = (SourceSessionKey) obj;
if (policy == null) {
- if (other.policy != null) {
- return false;
- }
+ if (other.policy != null) return false;
} else if (!policy.equals(other.policy)) {
return false;
}
- if (Double.doubleToLongBits(timeout) != Double.doubleToLongBits(other.timeout)) {
- return false;
- }
+ if (Double.doubleToLongBits(timeout) != Double.doubleToLongBits(other.timeout)) return false;
return true;
}
}