You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2018/04/27 20:50:15 UTC
[2/2] qpid-jms git commit: NO-JIRA Fix some warnings in the
MockProvider test class
NO-JIRA Fix some warnings in the MockProvider test class
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/9653d8b1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/9653d8b1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/9653d8b1
Branch: refs/heads/master
Commit: 9653d8b11f61e3f6130413739d9ee3624b2eaaa5
Parents: b23b6e4
Author: Timothy Bish <ta...@gmail.com>
Authored: Fri Apr 27 16:49:57 2018 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Fri Apr 27 16:49:57 2018 -0400
----------------------------------------------------------------------
.../jms/provider/mock/MockProviderStats.java | 21 +++++++++-----------
1 file changed, 9 insertions(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9653d8b1/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/mock/MockProviderStats.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/mock/MockProviderStats.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/mock/MockProviderStats.java
index 9c056d8..74a1e31 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/mock/MockProviderStats.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/mock/MockProviderStats.java
@@ -17,6 +17,7 @@
package org.apache.qpid.jms.provider.mock;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.qpid.jms.meta.JmsResource;
@@ -45,14 +46,10 @@ public class MockProviderStats {
private final AtomicInteger unsubscribeCalls = new AtomicInteger();
private final AtomicInteger pullCalls = new AtomicInteger();
- private final ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger> resourceCreateCalls =
- new ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger>();
- private final ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger> resourceStartCalls =
- new ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger>();
- private final ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger> resourceStopCalls =
- new ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger>();
- private final ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger> resourceDestroyCalls =
- new ConcurrentHashMap<Class<? extends JmsResource>, AtomicInteger>();
+ private final ConcurrentMap<Class<? extends JmsResource>, AtomicInteger> resourceCreateCalls = new ConcurrentHashMap<>();
+ private final ConcurrentMap<Class<? extends JmsResource>, AtomicInteger> resourceStartCalls = new ConcurrentHashMap<>();
+ private final ConcurrentMap<Class<? extends JmsResource>, AtomicInteger> resourceStopCalls = new ConcurrentHashMap<>();
+ private final ConcurrentMap<Class<? extends JmsResource>, AtomicInteger> resourceDestroyCalls = new ConcurrentHashMap<>();
public MockProviderStats() {
this(null);
@@ -117,7 +114,7 @@ public class MockProviderStats {
}
createResourceCalls.incrementAndGet();
- AtomicInteger count = resourceCreateCalls.get(resource);
+ AtomicInteger count = resourceCreateCalls.get(resource.getClass());
if (count != null) {
count.incrementAndGet();
} else {
@@ -144,7 +141,7 @@ public class MockProviderStats {
}
startResourceCalls.incrementAndGet();
- AtomicInteger count = resourceStartCalls.get(resource);
+ AtomicInteger count = resourceStartCalls.get(resource.getClass());
if (count != null) {
count.incrementAndGet();
} else {
@@ -171,7 +168,7 @@ public class MockProviderStats {
}
stopResourceCalls.incrementAndGet();
- AtomicInteger count = resourceStopCalls.get(resource);
+ AtomicInteger count = resourceStopCalls.get(resource.getClass());
if (count != null) {
count.incrementAndGet();
} else {
@@ -198,7 +195,7 @@ public class MockProviderStats {
}
destroyResourceCalls.incrementAndGet();
- AtomicInteger count = resourceDestroyCalls.get(resource);
+ AtomicInteger count = resourceDestroyCalls.get(resource.getClass());
if (count != null) {
count.incrementAndGet();
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org