Skip to content

Commit

Permalink
增加时间测试
Browse files Browse the repository at this point in the history
  • Loading branch information
@chengyouling
chengyouling committed Jan 15, 2025
1 parent bd35f60 commit 8598b6b
Showing 1 changed file with 18 additions and 18 deletions.
36 changes: 18 additions & 18 deletions ...t/src/test/java/io/sermant/demo/grayscale/rocketmq/integration/GrayscaleRocketmqTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ private void testPluginEnabledFalsePull() throws InterruptedException {

private void testPluginEnabledFalseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -79,7 +79,7 @@ private void testPluginEnabledFalseLitePull() throws InterruptedException {

private void testPluginEnabledFalsePush() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -118,7 +118,7 @@ private void testAutoOnlyBasePull() throws InterruptedException {

private void testAutoOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -128,7 +128,7 @@ private void testAutoOnlyBaseLitePull() throws InterruptedException {

private void testAutoOnlyBasePush() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -159,7 +159,7 @@ private void testAutoExcOnlyBasePull() throws InterruptedException {

private void testAutoExcOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -169,7 +169,7 @@ private void testAutoExcOnlyBaseLitePull() throws InterruptedException {

private void testAutoExcOnlyBasePush() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -206,7 +206,7 @@ public void testAutoBaseGrayPull() throws InterruptedException {
public void testAutoBaseGrayLitePull() throws InterruptedException {
createGrayscaleConfig("AUTO", "");
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String grayResult = getLitePullGrayResult();
int grayBaseCount = parseBaseMessageCount(grayResult);
int grayGrayCount = parseGrayMessageCount(grayResult);
Expand All @@ -221,7 +221,7 @@ public void testAutoBaseGrayLitePull() throws InterruptedException {
public void testAutoBaseGrayPush() throws InterruptedException {
createGrayscaleConfig("AUTO", "");
initAndProduceMessage(true, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -257,7 +257,7 @@ private void testAutoExcBaseGrayPull() throws InterruptedException {

private void testAutoExcBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -270,7 +270,7 @@ private void testAutoExcBaseGrayLitePull() throws InterruptedException {

private void testAutoExcBaseGrayPush() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -304,7 +304,7 @@ private void testBaseOnlyBasePull() throws InterruptedException {

private void testBaseOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -314,7 +314,7 @@ private void testBaseOnlyBaseLitePull() throws InterruptedException {

private void testBaseOnlyBasePush() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -345,7 +345,7 @@ private void testBaseExcOnlyBasePull() throws InterruptedException {

private void testBaseExcOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -355,7 +355,7 @@ private void testBaseExcOnlyBaseLitePull() throws InterruptedException {

private void testBaseExcOnlyBasePush() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -389,7 +389,7 @@ private void testBaseBaseGrayPull() throws InterruptedException {

private void testBaseBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -402,7 +402,7 @@ private void testBaseBaseGrayLitePull() throws InterruptedException {

private void testBaseBaseGrayPush() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -439,7 +439,7 @@ private void testBaseExcBaseGrayPull() throws InterruptedException {

private void testBaseExcBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getLitePullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -452,7 +452,7 @@ private void testBaseExcBaseGrayLitePull() throws InterruptedException {

private void testBaseExcBaseGrayPush() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PUSH);
Thread.sleep(200000);
Thread.sleep(240000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down

0 comments on commit 8598b6b

Please sign in to comment.