Skip to content

GEODE-10588:Replace deprecated-for-removal primitive-wrapper constructors in geode-cq distributed tests with equivalent valueOf calls. #8012

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
hubgeter wants to merge 1 commit into
base: develop
Choose a base branch
from
+16 −16
Open

GEODE-10588:Replace deprecated-for-removal primitive-wrapper constructors in geode-cq distributed tests with equivalent valueOf calls. #8012

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/CqDataDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -910,7 +910,7 @@ public void run2() throws CacheException {
// Check if the events from CqListener are in order.
int oldId = 0;
for (Object cqEvent : cqListener.events.toArray()) {
int newId = new Integer(cqEvent.toString());
int newId = Integer.valueOf(cqEvent.toString());
if (oldId > newId) {
fail("Queued events for CQ Listener during execution with "
+ "Initial results is not in the order in which they are created.");
Expand Down Expand Up @@ -1067,7 +1067,7 @@ public void run2() throws CacheException {
// Check if the events from CqListener are in order.
int oldId = 0;
for (Object cqEvent : cqListener.events.toArray()) {
int newId = new Integer(cqEvent.toString());
int newId = Integer.valueOf(cqEvent.toString());
if (oldId > newId) {
fail("Queued events for CQ Listener during execution with "
+ "Initial results is not in the order in which they are created.");
Expand Down
2 changes: 1 addition & 1 deletion .../distributedTest/java/org/apache/geode/cache/query/cq/dunit/CqDataUsingPoolDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -785,7 +785,7 @@ public String description() {
// Check if the events from CqListener are in order.
int oldId = 0;
for (Object cqEvent : cqListener.events.toArray()) {
int newId = new Integer(cqEvent.toString());
int newId = Integer.valueOf(cqEvent.toString());
if (oldId > newId) {
fail("Queued events for CQ Listener during execution with "
+ "Initial results is not in the order in which they are created.");
Expand Down
2 changes: 1 addition & 1 deletion ...e-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/CqQueryDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -473,7 +473,7 @@ public void run2() throws CacheException {
Region region1 = getRootRegion().getSubregion(regionName);
for (int i = 1; i <= size; i++) {
Portfolio portfolio = new Portfolio(i);
portfolio.shortID = new Short("" + i);
portfolio.shortID = Short.valueOf("" + i);
region1.put(KEY + i, portfolio);
}
logger.info("### Number of Entries in Region :" + region1.keySet().size());
Expand Down
2 changes: 1 addition & 1 deletion ...tedTest/java/org/apache/geode/cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1124,7 +1124,7 @@ public void run2() throws CacheException {
// Check if the events from CqListener are in order.
int oldId = 0;
for (Object cqEvent : cqListener.events.toArray()) {
int newId = new Integer(cqEvent.toString());
int newId = Integer.valueOf(cqEvent.toString());
if (oldId > newId) {
fail("Queued events for CQ Listener during execution with "
+ "Initial results is not in the order in which they are created.");
Expand Down
2 changes: 1 addition & 1 deletion ...rc/distributedTest/java/org/apache/geode/cache/query/cq/dunit/PrCqUsingPoolDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1160,7 +1160,7 @@ public void run2() throws CacheException {
// Check if the events from CqListener are in order.
int oldId = 0;
for (Object cqEvent : cqListener.events.toArray()) {
int newId = new Integer(cqEvent.toString());
int newId = Integer.valueOf(cqEvent.toString());
if (oldId > newId) {
fail("Queued events for CQ Listener during execution with "
+ "Initial results is not in the order in which they are created.");
Expand Down
20 changes: 10 additions & 10 deletions ...dTest/java/org/apache/geode/internal/cache/tier/sockets/ClientToServerDeltaDUnitTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -172,11 +172,11 @@ public void initialise(Boolean clone, String[] queries, Boolean cq, Boolean RI,
.createServerCache(Boolean.TRUE, Boolean.FALSE, clone, enableDelta));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.FALSE, Boolean.FALSE));

client2.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server2.getHost()), new Integer(PORT2), Boolean.TRUE,
NetworkUtils.getServerHostName(server2.getHost()), Integer.valueOf(PORT2), Boolean.TRUE,
Boolean.FALSE, cq, queries, RI));
}

Expand All @@ -190,11 +190,11 @@ public void initialise2(Boolean clone, String[] queries, Boolean cq, Boolean RI,
.createServerCache(Boolean.FALSE, Boolean.FALSE, clone, enableDelta));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.FALSE, Boolean.FALSE));

client2.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server2.getHost()), new Integer(PORT2), Boolean.TRUE,
NetworkUtils.getServerHostName(server2.getHost()), Integer.valueOf(PORT2), Boolean.TRUE,
Boolean.FALSE, cq, queries, RI));
}

Expand Down Expand Up @@ -301,7 +301,7 @@ public void testClientDeltaPropogationPutFetchesTheLatestValueWhenClientVersionI
.createServerCache(Boolean.TRUE, Boolean.FALSE, Boolean.TRUE, Boolean.TRUE));

ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.FALSE, Boolean.FALSE, null, Boolean.FALSE);
Region r = cache.getRegion(REGION_NAME);
DeltaTestImpl val = new DeltaTestImpl(0, "0", (double) 0, new byte[0],
Expand Down Expand Up @@ -835,7 +835,7 @@ public void testEmptyClientAsFeederToServer() {
.invoke(() -> ClientToServerDeltaDUnitTest.createServerCache(Boolean.FALSE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.TRUE, Boolean.FALSE));

/*
Expand Down Expand Up @@ -866,7 +866,7 @@ public void testEmptyServerAsFeederToPeer() {
.invoke(() -> ClientToServerDeltaDUnitTest.createServerCache(Boolean.FALSE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.TRUE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.putDelta(KEY1));
Expand All @@ -892,11 +892,11 @@ public void testClientsConnectedToEmptyServer() {
.invoke(() -> ClientToServerDeltaDUnitTest.createServerCache(Boolean.FALSE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.TRUE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.TRUE,
Boolean.TRUE, Boolean.FALSE));

client2.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.TRUE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.TRUE,
Boolean.FALSE, Boolean.FALSE));

int deltaSent =
Expand All @@ -922,7 +922,7 @@ public void testClientNonEmptyEmptyServerAsFeederToPeer() {
.invoke(() -> ClientToServerDeltaDUnitTest.createServerCache(Boolean.FALSE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.createClientCache(
NetworkUtils.getServerHostName(server.getHost()), new Integer(PORT1), Boolean.FALSE,
NetworkUtils.getServerHostName(server.getHost()), Integer.valueOf(PORT1), Boolean.FALSE,
Boolean.FALSE, Boolean.FALSE));

client.invoke(() -> ClientToServerDeltaDUnitTest.putDelta(KEY1));
Expand Down
Loading