Package com.alibaba.rocketmq.common.protocol.body

Examples of com.alibaba.rocketmq.common.protocol.body.QueryCorrectionOffsetBody

1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
                    correctionOffset.get(queueId) > compareOffset.get(queueId) ? Long.MAX_VALUE
                            : correctionOffset.get(queueId));
            }
        }

        QueryCorrectionOffsetBody body = new QueryCorrectionOffsetBody();
        body.setCorrectionOffsets(correctionOffset);
        response.setBody(body.encode());
        response.setCode(ResponseCode.SUCCESS);
        response.setRemark(null);
        return response;
    }
View Full Code Here
2228
2229
2230
2231
2232
2233
2234
2235
2236
2237
2238
2239
2240
        RemotingCommand response = this.remotingClient.invokeSync(addr, request, timeoutMillis);
        assert response != null;
        switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            if (response.getBody() != null) {
                QueryCorrectionOffsetBody body =
                        QueryCorrectionOffsetBody.decode(response.getBody(), QueryCorrectionOffsetBody.class);
                return body.getCorrectionOffsets();
            }
        }
        default:
            break;
        }
View Full Code Here
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
                    correctionOffset.get(queueId) > compareOffset.get(queueId) ? Long.MAX_VALUE
                            : correctionOffset.get(queueId));
            }
        }

        QueryCorrectionOffsetBody body = new QueryCorrectionOffsetBody();
        body.setCorrectionOffsets(correctionOffset);
        response.setBody(body.encode());
        response.setCode(ResponseCode.SUCCESS);
        response.setRemark(null);
        return response;
    }
View Full Code Here
2243
2244
2245
2246
2247
2248
2249
2250
2251
2252
2253
2254
2255
        RemotingCommand response = this.remotingClient.invokeSync(addr, request, timeoutMillis);
        assert response != null;
        switch (response.getCode()) {
        case ResponseCode.SUCCESS: {
            if (response.getBody() != null) {
                QueryCorrectionOffsetBody body =
                        QueryCorrectionOffsetBody.decode(response.getBody(), QueryCorrectionOffsetBody.class);
                return body.getCorrectionOffsets();
            }
        }
        default:
            break;
        }
View Full Code Here
TOP

Related Classes of com.alibaba.rocketmq.common.protocol.body.QueryCorrectionOffsetBody

  • com.alibaba.rocketmq.broker.processor.AdminBrokerProcessor
  • com.alibaba.rocketmq.client.impl.MQClientAPIImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.