Skip to content

Commit effbefb

Browse files
zstanMmuzaf
authored andcommitted
IGNITE-12122 Remove setIncludeEventTypes from GridAbstractTest (apache#6825)
IGNITE-12122: Remove setIncludeEventTypes from GridAbstractTest
1 parent fc69c33 commit effbefb

File tree

62 files changed

+248
-26
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

62 files changed

+248
-26
lines changed

modules/aop/src/test/java/org/apache/ignite/gridify/AbstractAopTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import org.apache.ignite.configuration.DeploymentMode;
2626
import org.apache.ignite.configuration.IgniteConfiguration;
2727
import org.apache.ignite.events.Event;
28+
import org.apache.ignite.events.EventType;
2829
import org.apache.ignite.internal.util.typedef.F;
2930
import org.apache.ignite.lang.IgnitePredicate;
3031
import org.apache.ignite.spi.deployment.local.LocalDeploymentSpi;
@@ -52,6 +53,8 @@ public abstract class AbstractAopTest extends GridCommonAbstractTest {
5253
cfg.setMetricsUpdateFrequency(500);
5354
cfg.setDeploymentMode(depMode);
5455

56+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
57+
5558
return cfg;
5659
}
5760

modules/camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,9 @@
4848
import org.apache.ignite.IgniteDataStreamer;
4949
import org.apache.ignite.IgniteException;
5050
import org.apache.ignite.cache.CachePeekMode;
51+
import org.apache.ignite.configuration.IgniteConfiguration;
5152
import org.apache.ignite.events.CacheEvent;
53+
import org.apache.ignite.events.EventType;
5254
import org.apache.ignite.internal.util.lang.GridMapEntry;
5355
import org.apache.ignite.internal.util.typedef.F;
5456
import org.apache.ignite.lang.IgniteBiPredicate;
@@ -96,6 +98,11 @@ public IgniteCamelStreamerTest() {
9698
super(true);
9799
}
98100

101+
/** {@inheritDoc} */
102+
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
103+
return super.getConfiguration(igniteInstanceName).setIncludeEventTypes(EventType.EVTS_ALL);
104+
}
105+
99106
@SuppressWarnings("unchecked")
100107
@Override public void beforeTest() throws Exception {
101108
grid().<Integer, String>getOrCreateCache(defaultCacheConfiguration());

modules/clients/src/test/java/org/apache/ignite/internal/TaskEventSubjectIdSelfTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import org.apache.ignite.configuration.ConnectorConfiguration;
3636
import org.apache.ignite.configuration.IgniteConfiguration;
3737
import org.apache.ignite.events.Event;
38+
import org.apache.ignite.events.EventType;
3839
import org.apache.ignite.events.TaskEvent;
3940
import org.apache.ignite.internal.client.GridClient;
4041
import org.apache.ignite.internal.client.GridClientConfiguration;
@@ -76,6 +77,8 @@ public class TaskEventSubjectIdSelfTest extends GridCommonAbstractTest {
7677

7778
cfg.setConnectorConfiguration(new ConnectorConfiguration());
7879

80+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
81+
7982
return cfg;
8083
}
8184

modules/core/src/test/java/org/apache/ignite/failure/OomFailureHandlerTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ public class OomFailureHandlerTest extends AbstractFailureHandlerTest {
5252
.setBackups(0)
5353
);
5454

55+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
56+
5557
return cfg;
5658
}
5759

modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupAbstractTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import org.apache.ignite.compute.ComputeTaskSplitAdapter;
4343
import org.apache.ignite.configuration.IgniteConfiguration;
4444
import org.apache.ignite.events.Event;
45+
import org.apache.ignite.events.EventType;
4546
import org.apache.ignite.internal.util.typedef.F;
4647
import org.apache.ignite.internal.util.typedef.G;
4748
import org.apache.ignite.lang.IgniteBiTuple;
@@ -117,6 +118,8 @@ protected ClusterGroupAbstractTest() {
117118
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
118119
IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);
119120

121+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
122+
120123
((TcpDiscoverySpi)cfg.getDiscoverySpi()).setForceServerMode(true);
121124

122125
return cfg;

modules/core/src/test/java/org/apache/ignite/internal/ClusterMetricsSelfTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import org.apache.ignite.configuration.IgniteConfiguration;
3030
import org.apache.ignite.events.DiscoveryEvent;
3131
import org.apache.ignite.events.Event;
32+
import org.apache.ignite.events.EventType;
3233
import org.apache.ignite.internal.util.typedef.F;
3334
import org.apache.ignite.internal.util.typedef.G;
3435
import org.apache.ignite.lang.IgnitePredicate;
@@ -62,7 +63,7 @@ public class ClusterMetricsSelfTest extends GridCommonAbstractTest {
6263

6364
cfg.setCacheConfiguration();
6465
cfg.setIncludeProperties();
65-
//cfg.setMetricsUpdateFrequency(0);
66+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
6667

6768
return cfg;
6869
}

modules/core/src/test/java/org/apache/ignite/internal/GridDeploymentSelfTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import org.apache.ignite.compute.ComputeTaskName;
3535
import org.apache.ignite.configuration.IgniteConfiguration;
3636
import org.apache.ignite.events.Event;
37+
import org.apache.ignite.events.EventType;
3738
import org.apache.ignite.lang.IgnitePredicate;
3839
import org.apache.ignite.resources.LoggerResource;
3940
import org.apache.ignite.spi.IgniteSpiException;
@@ -77,6 +78,8 @@ public class GridDeploymentSelfTest extends GridCommonAbstractTest {
7778
// Disable cache since it can deploy some classes during start process.
7879
cfg.setCacheConfiguration();
7980

81+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
82+
8083
return cfg;
8184
}
8285

modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
import org.apache.ignite.events.CheckpointEvent;
4141
import org.apache.ignite.events.DeploymentEvent;
4242
import org.apache.ignite.events.Event;
43+
import org.apache.ignite.events.EventType;
4344
import org.apache.ignite.events.JobEvent;
4445
import org.apache.ignite.events.TaskEvent;
4546
import org.apache.ignite.internal.util.IgniteUtils;
@@ -99,6 +100,8 @@ public GridEventStorageCheckAllEventsSelfTest() {
99100
// TODO: IGNITE-3099 (hotfix the test to check the event order in common case).
100101
cfg.setPublicThreadPoolSize(1);
101102

103+
cfg.setIncludeEventTypes(EventType.EVTS_ALL);
104+
102105
return cfg;
103106
}
104107

modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,9 @@
3131
import org.apache.ignite.compute.ComputeJobAdapter;
3232
import org.apache.ignite.compute.ComputeJobResult;
3333
import org.apache.ignite.compute.ComputeTaskSplitAdapter;
34+
import org.apache.ignite.configuration.IgniteConfiguration;
3435
import org.apache.ignite.events.Event;
36+
import org.apache.ignite.events.EventType;
3537
import org.apache.ignite.events.JobEvent;
3638
import org.apache.ignite.events.TaskEvent;
3739
import org.apache.ignite.internal.processors.task.GridInternal;
@@ -69,6 +71,11 @@ public GridEventStorageSelfTest() {
6971
super(/*start grid*/false);
7072
}
7173

74+
/** {@inheritDoc} */
75+
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
76+
return super.getConfiguration(igniteInstanceName).setIncludeEventTypes(EventType.EVTS_ALL);
77+
}
78+
7279
/** {@inheritDoc} */
7380
@Override protected void beforeTest() throws Exception {
7481
ignite1 = startGrid(1);

modules/core/src/test/java/org/apache/ignite/internal/GridJobSubjectIdSelfTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import org.apache.ignite.compute.ComputeJobResult;
2929
import org.apache.ignite.compute.ComputeTaskAdapter;
3030
import org.apache.ignite.compute.ComputeTaskSession;
31+
import org.apache.ignite.configuration.IgniteConfiguration;
3132
import org.apache.ignite.events.Event;
3233
import org.apache.ignite.events.EventType;
3334
import org.apache.ignite.events.JobEvent;
@@ -60,6 +61,11 @@ public class GridJobSubjectIdSelfTest extends GridCommonAbstractTest {
6061
/** Second node. */
6162
private Ignite node2;
6263

64+
/** {@inheritDoc} */
65+
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
66+
return super.getConfiguration(igniteInstanceName).setIncludeEventTypes(EventType.EVTS_ALL);
67+
}
68+
6369
/** {@inheritDoc} */
6470
@Override protected void beforeTest() throws Exception {
6571
node1 = startGrid(1);

0 commit comments

Comments
 (0)