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 7f7c59b commit c0be15d
Showing 1 changed file with 27 additions and 27 deletions.
54 changes: 27 additions & 27 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 @@ -59,7 +59,7 @@ public void testPluginEnabledFalseConsumeMessage() throws InterruptedException {

private void testPluginEnabledFalsePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -69,7 +69,7 @@ private void testPluginEnabledFalsePull() throws InterruptedException {

private void testPluginEnabledFalseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down Expand Up @@ -108,7 +108,7 @@ public void testAutoOnlyBaseConsumeMessage() throws InterruptedException {

private void testAutoOnlyBasePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -118,7 +118,7 @@ private void testAutoOnlyBasePull() throws InterruptedException {

private void testAutoOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -149,7 +149,7 @@ public void testAutoExcOnlyBaseConsumeMessage() throws InterruptedException {

private void testAutoExcOnlyBasePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -159,7 +159,7 @@ private void testAutoExcOnlyBasePull() throws InterruptedException {

private void testAutoExcOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -193,7 +193,7 @@ public void testAutoBaseGrayConsumeMessage() throws InterruptedException {
public void testAutoBaseGrayPull() throws InterruptedException {
createGrayscaleConfig("AUTO", "");
initAndProduceMessage(true, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String grayResult = getPullGrayResult();
int grayGrayCount = parseGrayMessageCount(grayResult);
String baseResult = getPullBaseResult();
Expand All @@ -206,7 +206,7 @@ public void testAutoBaseGrayPull() throws InterruptedException {
public void testAutoBaseGrayLitePull() throws InterruptedException {
createGrayscaleConfig("AUTO", "");
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -244,7 +244,7 @@ public void testAutoExcBaseGrayConsumeMessage() throws InterruptedException {

private void testAutoExcBaseGrayPull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String grayResult = getPullGrayResult();
int grayBaseCount = parseBaseMessageCount(grayResult);
int grayGrayCount = parseGrayMessageCount(grayResult);
Expand All @@ -257,7 +257,7 @@ private void testAutoExcBaseGrayPull() throws InterruptedException {

private void testAutoExcBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -294,7 +294,7 @@ public void testBaseOnlyBaseConsumeMessage() throws InterruptedException {

private void testBaseOnlyBasePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -304,7 +304,7 @@ private void testBaseOnlyBasePull() throws InterruptedException {

private void testBaseOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -335,7 +335,7 @@ public void testBaseExcOnlyBaseConsumeMessage() throws InterruptedException {

private void testBaseExcOnlyBasePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -345,7 +345,7 @@ private void testBaseExcOnlyBasePull() throws InterruptedException {

private void testBaseExcOnlyBaseLitePull() throws InterruptedException {
initAndProduceMessage(false, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -376,7 +376,7 @@ public void testBaseBaseGrayConsumeMessage() throws InterruptedException {

private void testBaseBaseGrayPull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -389,7 +389,7 @@ private void testBaseBaseGrayPull() throws InterruptedException {

private void testBaseBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -426,7 +426,7 @@ public void testBaseExcBaseGrayConsumeMessage() throws InterruptedException {

private void testBaseExcBaseGrayPull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_PULL);
Thread.sleep(120000);
Thread.sleep(150000);
String baseResult = getPullBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand All @@ -439,7 +439,7 @@ private void testBaseExcBaseGrayPull() throws InterruptedException {

private void testBaseExcBaseGrayLitePull() throws InterruptedException {
initAndProduceMessage(true, CONSUMER_TYPE_LITE_PULL);
Thread.sleep(180000);
Thread.sleep(200000);
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(180000);
Thread.sleep(200000);
String baseResult = getPushBaseResult();
int baseBaseCount = parseBaseMessageCount(baseResult);
int baseGrayCount = parseGrayMessageCount(baseResult);
Expand Down

0 comments on commit c0be15d

Please sign in to comment.