Skip to content

Commit cbb1d0c

Browse files
authored
IGNITE-25533 Remove Message#onAckReceived (#12209)
1 parent a2a61c6 commit cbb1d0c

File tree

120 files changed

+4
-601
lines changed

Some content is hidden

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

120 files changed

+4
-601
lines changed

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessage.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,4 @@ public interface CalciteMessage extends Message {
3232
@Override default short directType() {
3333
return type().directType();
3434
}
35-
36-
/** {@inheritDoc} */
37-
@Override default void onAckReceived() {
38-
// No-op.
39-
}
4035
}

modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -126,11 +126,6 @@ public void system(boolean system) {
126126
this.system = system;
127127
}
128128

129-
/** {@inheritDoc} */
130-
@Override public void onAckReceived() {
131-
// No-op.
132-
}
133-
134129
/** {@inheritDoc} */
135130
@Override public short directType() {
136131
return 0;

modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -487,11 +487,6 @@ public AffinityTopologyVersion getTopVer() {
487487
return topVer;
488488
}
489489

490-
/** {@inheritDoc} */
491-
@Override public void onAckReceived() {
492-
// No-op.
493-
}
494-
495490
/** {@inheritDoc} */
496491
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
497492
writer.setBuffer(buf);

modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -223,11 +223,6 @@ public AffinityTopologyVersion getRetryTopologyVersion() {
223223
return retry != null ? retry : AffinityTopologyVersion.NONE;
224224
}
225225

226-
/** {@inheritDoc} */
227-
@Override public void onAckReceived() {
228-
// No-op.
229-
}
230-
231226
/** {@inheritDoc} */
232227
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
233228
writer.setBuffer(buf);

modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -79,11 +79,6 @@ public void topicId(long topicId) {
7979
this.topicId = topicId;
8080
}
8181

82-
/** {@inheritDoc} */
83-
@Override public void onAckReceived() {
84-
// No-op.
85-
}
86-
8782
/** {@inheritDoc} */
8883
@Override public short directType() {
8984
return 3;

modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -74,11 +74,6 @@ public void unmarshalSiblings(Marshaller marsh) throws IgniteCheckedException {
7474
siblings = U.unmarshal(marsh, siblingsBytes, null);
7575
}
7676

77-
/** {@inheritDoc} */
78-
@Override public void onAckReceived() {
79-
// No-op.
80-
}
81-
8277
/** {@inheritDoc} */
8378
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
8479
writer.setBuffer(buf);

modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -61,11 +61,6 @@ public void sessionId(IgniteUuid sesId) {
6161
this.sesId = sesId;
6262
}
6363

64-
/** {@inheritDoc} */
65-
@Override public void onAckReceived() {
66-
// No-op.
67-
}
68-
6964
/** {@inheritDoc} */
7065
@Override public short directType() {
7166
return 5;

modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,11 +94,6 @@ public IgniteUuid getJobId() {
9494
return jobId;
9595
}
9696

97-
/** {@inheritDoc} */
98-
@Override public void onAckReceived() {
99-
// No-op.
100-
}
101-
10297
/** {@inheritDoc} */
10398
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
10499
writer.setBuffer(buf);

modules/core/src/main/java/org/apache/ignite/internal/IgniteDiagnosticMessage.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -211,11 +211,6 @@ public boolean request() {
211211
return -61;
212212
}
213213

214-
/** {@inheritDoc} */
215-
@Override public void onAckReceived() {
216-
// No-op.
217-
}
218-
219214
/**
220215
*
221216
*/

modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -104,11 +104,6 @@ public void checkpointSpi(String cpSpi) {
104104
this.cpSpi = cpSpi;
105105
}
106106

107-
/** {@inheritDoc} */
108-
@Override public void onAckReceived() {
109-
// No-op.
110-
}
111-
112107
/** {@inheritDoc} */
113108
@Override public short directType() {
114109
return 7;

0 commit comments

Comments
 (0)