{Start,Stop}DropMessages is generic

Add a diamond to constructor invocations to remove warnings.

Change-Id: I29f063eaf65656aef6715a8fe710e2afb35169e7
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
index 32718440c1d4b0ed9eeda84ddea7174a31ba8874..d82ae0fd7702be863be45207ee8a65c553e9761e 100644 (file)
--- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
@@ -1407,8 +1407,8 @@ public class DistributedDataStoreRemotingIntegrationTest extends AbstractTest {
                     .getLocalShards().get("cars").getActor();
             final ActorRef member2Cars = ((LocalShardStore)followerDistributedDataStore).getLocalShards()
                     .getLocalShards().get("cars").getActor();
-            member2Cars.tell(new StartDropMessages(AppendEntries.class), null);
-            member3Cars.tell(new StartDropMessages(AppendEntries.class), null);
+            member2Cars.tell(new StartDropMessages<>(AppendEntries.class), null);
+            member3Cars.tell(new StartDropMessages<>(AppendEntries.class), null);
 
             final DOMStoreWriteTransaction newTx = leaderDistributedDataStore.newWriteOnlyTransaction();
             newTx.write(CarsModel.CAR_LIST_PATH, CarsModel.newCarMapNode());
@@ -1436,8 +1436,8 @@ public class DistributedDataStoreRemotingIntegrationTest extends AbstractTest {
                     "member-3-shard-cars-testRaftCallbackDuringLeadershipDrop", -1,
                             -1), member3Cars);
 
-            member2Cars.tell(new StopDropMessages(AppendEntries.class), null);
-            member3Cars.tell(new StopDropMessages(AppendEntries.class), null);
+            member2Cars.tell(new StopDropMessages<>(AppendEntries.class), null);
+            member3Cars.tell(new StopDropMessages<>(AppendEntries.class), null);
 
             await("Is tx stuck in COMMIT_PENDING")
                     .atMost(10, TimeUnit.SECONDS).untilAtomic(submitDone, equalTo(true));