org.junit.jupiter.api.Timeout源码实例Demo

类org.junit.jupiter.api.Timeout源码实例Demo

下面列出了org.junit.jupiter.api.Timeout 类实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

@Test
@Timeout(90)
public void testIndexOperation() {
    try {
        String topic = TestUtils.getDefaultTestTopic(this.getClass());

        ConnectorPropertyFactory propertyFactory = CamelElasticSearchPropertyFactory
                .basic()
                .withTopics(topic)
                .withOperation("Index")
                .withClusterName(ElasticSearchCommon.DEFAULT_ELASTICSEARCH_CLUSTER)
                .withHostAddress(elasticSearch.getHttpHostAddress())
                .withIndexName(ElasticSearchCommon.DEFAULT_ELASTICSEARCH_INDEX)
                .withTransformsConfig("ElasticSearchTransformer")
                    .withEntry("type", "org.apache.camel.kafkaconnector.elasticsearch.sink.transform.ConnectRecordValueToMapTransformer")
                    .withEntry("key", transformKey)
                    .end();

        runTest(propertyFactory);

        LOG.debug("Created the consumer ... About to receive messages");
    } catch (Exception e) {
        LOG.error("ElasticSearch test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceive() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelSlackPropertyFactory
                .basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withChannel(slackChannel)
                .withWebhookUrl(webhookUrl);

        runTest(connectorPropertyFactory, "Sink test message sent to Slack from testBasicSendReceive");

    } catch (Exception e) {
        LOG.error("Slack test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceiveWithUrl() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelSlackPropertyFactory
                .basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withUrl(slackChannel)
                    .append("webhookUrl", webhookUrl)
                    .buildUrl();

        runTest(connectorPropertyFactory, "Sink test message sent to Slack from testBasicSendReceiveWithUrl");

    } catch (Exception e) {
        LOG.error("Slack test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceiveUsingUrl() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelFilePropertyFactory.basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withUrl(SINK_DIR)
                    .append("fileName", FILENAME)
                    .append("doneFileName", FILENAME + ".done")
                    .buildUrl();


        runTest(connectorPropertyFactory);

    } catch (Exception e) {
        LOG.error("HTTP test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceive() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelJMSPropertyFactory
                .basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withConnectionProperties(jmsService.getConnectionProperties())
                .withDestinationName(SJMS2Common.DEFAULT_JMS_QUEUE);

        runTest(connectorPropertyFactory);

    } catch (Exception e) {
        LOG.error("JMS test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceiveUsingUrl() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelJMSPropertyFactory
                .basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withConnectionProperties(jmsService.getConnectionProperties())
                    .withUrl(SJMS2Common.DEFAULT_JMS_QUEUE)
                    .buildUrl();

        runTest(connectorPropertyFactory);

    } catch (Exception e) {
        LOG.error("JMS test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
源代码7 项目: kogito-runtimes   文件: IntermediateEventTest.java
@Test
@Timeout(10)
public void testIntermediateCatchEventTimerCycle2() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("timer", 3);

    KieBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventTimerCycle2.bpmn2");
    ksession = createKnowledgeSession(kbase);
    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());
    ksession.addEventListener(countDownListener);

    ProcessInstance processInstance = ksession.startProcess("IntermediateCatchEvent");
    assertProcessInstanceActive(processInstance);
    // now wait for 1 second for timer to trigger
    countDownListener.waitTillCompleted();
    assertProcessInstanceActive(processInstance);
    ksession.abortProcessInstance(processInstance.getId());

}
 
源代码8 项目: kogito-runtimes   文件: IntermediateEventTest.java
@Test
@Timeout(10)
public void testIntermediateTimerParallelGateway() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("Timer1", 1);
    NodeLeftCountDownProcessEventListener countDownListener2 = new NodeLeftCountDownProcessEventListener("Timer2", 1);
    NodeLeftCountDownProcessEventListener countDownListener3 = new NodeLeftCountDownProcessEventListener("Timer3", 1);
    KieBase kbase = createKnowledgeBase("timer/BPMN2-IntermediateTimerParallelGateway.bpmn2");

    ksession = createKnowledgeSession(kbase);
    ksession.addEventListener(countDownListener);
    ksession.addEventListener(countDownListener2);
    ksession.addEventListener(countDownListener3);
    TestWorkItemHandler handler = new TestWorkItemHandler();

    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", handler);
    ProcessInstance processInstance = ksession.startProcess("Evaluation.timer-parallel");
    assertProcessInstanceActive(processInstance);

    countDownListener.waitTillCompleted();
    countDownListener2.waitTillCompleted();
    countDownListener3.waitTillCompleted();
    assertProcessInstanceCompleted(processInstance.getId(), ksession);

}
 
@DisabledIfSystemProperty(named = "aws-service.instance.type", matches = "remote")
@Test
@Timeout(value = 120)
@RepeatedTest(3)
public void testBasicSendReceiveUsingKafkaStyle() {
    try {
        Properties amazonProperties = awsService.getConnectionProperties();

        ConnectorPropertyFactory testProperties = CamelAWSSQSPropertyFactory
                .basic()
                .withName("CamelAwssqsSinkConnectorKafkaStyle")
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withAmazonConfig(amazonProperties, CamelAWSSQSPropertyFactory.KAFKA_STYLE)
                .withQueueNameOrArn(queueName);

        runTest(testProperties);

    } catch (Exception e) {
        LOG.error("Amazon SQS test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
源代码10 项目: kogito-runtimes   文件: IntermediateEventTest.java
@Test
@Timeout(10)
public void testIntermediateCatchEventTimerCycle1() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("timer", 1);

    KieBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventTimerCycle1.bpmn2");
    ksession = createKnowledgeSession(kbase);
    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());
    ksession.addEventListener(countDownListener);

    ProcessInstance processInstance = ksession.startProcess("IntermediateCatchEvent");
    assertProcessInstanceActive(processInstance);
    // now wait for 1 second for timer to trigger
    countDownListener.waitTillCompleted();

    ksession = restoreSession(ksession, true);
    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());

    assertProcessInstanceFinished(processInstance, ksession);

}
 
@Test
@Timeout(10)
public void testIntermediateCatchEventTimer() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("timer", 1);
    KieBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventTimerDuration.bpmn2");
    KieSession ksession = createKnowledgeSession(kbase);
    ksession.addEventListener(countDownListener);
    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());
    ProcessInstance processInstance = ksession.startProcess("IntermediateCatchEvent");
    assertThat(processInstance.getState()).isEqualTo(ProcessInstance.STATE_ACTIVE);
    // now wait for 1 second for timer to trigger
    countDownListener.waitTillCompleted();
    ksession = restoreSession(ksession, true);
    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());
    assertProcessInstanceCompleted(processInstance.getId(), ksession);
}
 
@Test
@Timeout(value = 90)
public void testBasicSendReceive() {
    try {
        final String sqsQueue = awsSqsClient.getQueue(AWSCommon.DEFAULT_SQS_QUEUE_FOR_SNS);
        LOG.info("Created SQS queue {}", sqsQueue);

        Properties amazonProperties = service.getConnectionProperties();

        ConnectorPropertyFactory connectorPropertyFactory = CamelAWSSNSPropertyFactory.basic()
                .withName("CamelAWSSNSSinkConnectorDefault")
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withTopicOrArn(AWSCommon.DEFAULT_SQS_QUEUE_FOR_SNS)
                .withSubscribeSNStoSQS(sqsQueue)
                .withConfiguration(TestSNSConfiguration.class.getName())
                .withAmazonConfig(amazonProperties);

        runTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("Amazon SNS test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(value = 90)
public void testBasicSendReceiveUsingKafkaStyle() {
    try {
        final String sqsQueue = awsSqsClient.getQueue(AWSCommon.DEFAULT_SQS_QUEUE_FOR_SNS);
        LOG.info("Created SQS queue {}", sqsQueue);

        Properties amazonProperties = service.getConnectionProperties();

        ConnectorPropertyFactory connectorPropertyFactory = CamelAWSSNSPropertyFactory.basic()
                .withName("CamelAWSSNSSinkKafkaStyleConnector")
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withTopicOrArn(AWSCommon.DEFAULT_SQS_QUEUE_FOR_SNS)
                .withSubscribeSNStoSQS(sqsQueue)
                .withConfiguration(TestSNSConfiguration.class.getName())
                .withAmazonConfig(amazonProperties, CamelAWSSNSPropertyFactory.KAFKA_STYLE);

        runTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("Amazon SNS test failed: {}", e.getMessage(), e);
        fail(e.getMessage());
    }
}
 
@Test
@Timeout(180)
public void testBasicSendReceiveUsingUrl() throws ExecutionException, InterruptedException {
    Properties amazonProperties = service.getConnectionProperties();

    ConnectorPropertyFactory connectorPropertyFactory = CamelAWSS3PropertyFactory
            .basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withConfiguration(TestS3Configuration.class.getName())
            .withUrl(AWSCommon.DEFAULT_S3_BUCKET)
                .append("accessKey", amazonProperties.getProperty(AWSConfigs.ACCESS_KEY))
                .append("secretKey", amazonProperties.getProperty(AWSConfigs.SECRET_KEY))
                .appendIfAvailable("proxyProtocol", amazonProperties.getProperty(AWSConfigs.PROTOCOL))
                .append("region", amazonProperties.getProperty(AWSConfigs.REGION, Regions.US_EAST_1.name()))
            .buildUrl();

    runTest(connectorPropertyFactory);
}
 
@Test
@Timeout(90)
public void testBasicSendReceive() throws ExecutionException, InterruptedException {
    String connectionBeanRef = String.format("com.mongodb.client.MongoClients#create('mongodb://%s:%d')",
            mongoDBService.getHost(),
            mongoDBService.getPort());

    CamelMongoDBPropertyFactory factory = CamelMongoDBPropertyFactory.basic()
            .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
            .withConnectionBean("mongo",
                    BasicConnectorPropertyFactory.classRef(connectionBeanRef))
            .withDatabase("testDB")
            .withCollection("testRecords")
            .withOperation("insert");

    runTest(factory);

    verifyDocuments("testDB", "testRecords");
}
 
@Test
@Timeout(90)
public void testFindAll() throws ExecutionException, InterruptedException {
    String connectionBeanRef = String.format("com.mongodb.client.MongoClients#create('mongodb://%s:%d')",
            mongoDBService.getHost(),
            mongoDBService.getPort());

    ConnectorPropertyFactory factory = CamelMongoDBPropertyFactory.basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withConnectionBean("mongo",
                    BasicConnectorPropertyFactory.classRef(connectionBeanRef))
            .withDatabase("testDatabase")
            .withCollection("testCollection")
            .withCreateCollection(true);

    runTest(factory);
}
 
@Test
@Timeout(90)
public void testBasicSendReceive() {
    try {
        String url = localServer.getInetAddress().getHostName() + ":" + HTTP_PORT + "/ckc";

        ConnectorPropertyFactory connectorPropertyFactory = CamelHTTPPropertyFactory.basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withHttpUri(url);

        runTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("HTTP test failed: {} {}", e.getMessage(), e);
        fail(e.getMessage(), e);
    }
}
 
@Test
@Timeout(90)
public void testBasicSendReceiveUsingUrl() {
    try {
        String hostName = localServer.getInetAddress().getHostName() + ":" + HTTP_PORT + "/ckc";

        ConnectorPropertyFactory connectorPropertyFactory = CamelHTTPPropertyFactory.basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withUrl(hostName)
                    .buildUrl();


        runTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("HTTP test failed: {} {}", e.getMessage(), e);
        fail(e.getMessage(), e);
    }
}
 
@Test
@Timeout(180)
public void testBasicProduce() throws ExecutionException, InterruptedException {
    ConnectorPropertyFactory factory = CamelSalesforcePropertyFactory.basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withUserName(userName)
            .withPassword(password)
            .withClientId(clientId)
            .withClientSecret(clientSecret)
            .withRawPayload(true)
            .withPackages("org.apache.camel.salesforce.dto")
            .withSObjectName("Account")
            .withOperationName("createSObject");

    runTest(factory);

    TestUtils.waitFor(this::waitForRecordCreation);
    assertTrue(recordCreated, "The record was not created");
}
 
@Test
@Timeout(180)
public void testBasicConsume() throws ExecutionException, InterruptedException {
    ConnectorPropertyFactory factory = CamelSalesforcePropertyFactory.basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withUserName(userName)
            .withPassword(password)
            .withClientId(clientId)
            .withClientSecret(clientSecret)
            .withNotifyForFields("ALL")
            .withUpdateTopic(true)
            .withRawPayload(true)
            .withPackages("org.apache.camel.salesforce.dto")
            .withSObjectClass("org.apache.camel.salesforce.dto.Account")
            .withSObjectQuery("SELECT Id, Name FROM Account")
            .withTopicName("CamelKafkaConnectorTopic");

    Executors.newCachedThreadPool().submit(this::updateTestAccount);

    runBasicTest(factory);
}
 
@Test
@Timeout(180)
public void testBasicConsumeUsingUrl() throws ExecutionException, InterruptedException {
    ConnectorPropertyFactory factory = CamelSalesforcePropertyFactory.basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withUserName(userName)
            .withPassword(password)
            .withClientId(clientId)
            .withClientSecret(clientSecret)
            .withUrl("CamelKafkaConnectorTopic")
                .append("notifyForFields", "ALL")
                .append("updateTopic", "true")
                .append("rawPayload", "true")
                .append("sObjectClass", "org.apache.camel.salesforce.dto.Account")
                .append("sObjectQuery", "SELECT Id, Name FROM Account")
                .buildUrl();

    Executors.newCachedThreadPool().submit(this::updateTestAccount);

    runBasicTest(factory);
}
 
@Test
@Timeout(180)
public void testBasicCDCUsingUrl() throws ExecutionException, InterruptedException {
    ConnectorPropertyFactory factory = CamelSalesforcePropertyFactory.basic()
            .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
            .withUserName(userName)
            .withPassword(password)
            .withClientId(clientId)
            .withClientSecret(clientSecret)
            .withApiVersion("37.0")
            .withUrl("data/AccountChangeEvent")
                .append("replayId", "-2")
                .append("rawPayload", "true")
                .buildUrl();

    runBasicTest(factory);
}
 
@Timeout(90)
@Test
public void testRetrieveFromCassandra() throws ExecutionException, InterruptedException {
    String topic = TestUtils.getDefaultTestTopic(this.getClass());

    ConnectorPropertyFactory connectorPropertyFactory = CamelCassandraPropertyFactory
            .basic()
            .withKafkaTopic(topic)
            .withHosts(cassandraService.getCassandraHost())
            .withPort(cassandraService.getCQL3Port())
            .withKeySpace(TestDataDao.KEY_SPACE)
            .withResultSetConversionStrategy("ONE")
            .withCql(testDataDao.getSelectStatement());

    runTest(connectorPropertyFactory);
}
 
@Disabled("Disabled due to CAMEL-15219")
@Timeout(90)
@Test
public void testRetrieveFromCassandraWithCustomStrategy() throws ExecutionException, InterruptedException {
    String topic = TestUtils.getDefaultTestTopic(this.getClass());

    ConnectorPropertyFactory connectorPropertyFactory = CamelCassandraPropertyFactory
            .basic()
            .withKafkaTopic(topic)
            .withHosts(cassandraService.getCassandraHost())
            .withPort(cassandraService.getCQL3Port())
            .withKeySpace(TestDataDao.KEY_SPACE)
            .withResultSetConversionStrategy("#:" + TestResultSetConversionStrategy.class.getName())
            .withCql(testDataDao.getSelectStatement());

    runTest(connectorPropertyFactory);
}
 
@Test
@Timeout(90)
public void testBasicReceive() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelSyslogPropertyFactory
                .basic()
                .withTopics(TestUtils.getDefaultTestTopic(this.getClass()))
                .withHost("localhost")
                .withPort(FREE_PORT)
                .withProtocol("udp");

        runBasicProduceTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("Syslog test failed: {} {}", e.getMessage(), e);
        fail(e.getMessage(), e);
    }
}
 
@Test
@Timeout(90)
public void testBasicSend() {
    try {
        ConnectorPropertyFactory connectorPropertyFactory = CamelSyslogPropertyFactory
                .basic()
                .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
                .withHost("localhost")
                .withPort(FREE_PORT)
                .withProtocol("udp");

        runBasicStringTest(connectorPropertyFactory);
    } catch (Exception e) {
        LOG.error("Syslog test failed: {} {}", e.getMessage(), e);
        fail(e.getMessage(), e);
    }
}
 
源代码27 项目: fastjgame   文件: EventLoopSanityTestGlobal.java
/**
 * 对于每一个生产者而言,都应该满足先入先出
 */
@Timeout(TEST_TIMEOUT)
@Test
void testFifo() {
    final int producerNum = 4;

    final AtomicBoolean stop = new AtomicBoolean();
    final LongHolder fail = new LongHolder();
    final long[] lastSequences = new long[producerNum];

    final FIFOProducer[] producers = new FIFOProducer[producerNum];
    for (int index = 0; index < producerNum; index++) {
        producers[index] = new FIFOProducer(stop, index, fail, lastSequences);
    }

    TestUtil.startAndJoin(Arrays.asList(producers), stop, 1000);

    Assertions.assertEquals(0, fail.get(), "Observed out of order");
}
 
源代码28 项目: fastjgame   文件: EventLoopSanityTest.java
/**
 * 对于每一个生产者而言,都应该满足先入先出
 */
@Timeout(TEST_TIMEOUT)
@Test
void testFifo() {
    final int producerNum = 4;

    // 必须使用abort策略,否则生产者无法感知失败
    final EventLoop eventLoop = newEventLoop(RejectedExecutionHandlers.abort());
    final LongHolder fail = new LongHolder();
    final long[] lastSequences = new long[producerNum];

    final FIFOProducer[] producers = new FIFOProducer[producerNum];
    for (int index = 0; index < producerNum; index++) {
        producers[index] = new FIFOProducer(eventLoop, index, fail, lastSequences);
    }

    TestUtil.startAndJoin(Arrays.asList(producers), eventLoop, 1000);

    Assertions.assertEquals(0, fail.get(), "Observed out of order");
}
 
源代码29 项目: kogito-runtimes   文件: IntermediateEventTest.java
@Test
@Timeout(10)
public void testIntermediateTimerEventMI() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("After timer", 3);
    KieBase kbase = createKnowledgeBase("timer/BPMN2-IntermediateTimerEventMI.bpmn2");

    ksession = createKnowledgeSession(kbase);
    ksession.addEventListener(countDownListener);
    TestWorkItemHandler handler = new TestWorkItemHandler();

    ksession.getWorkItemManager().registerWorkItemHandler("Human Task", handler);
    ProcessInstance processInstance = ksession.startProcess("defaultprocessid");
    assertProcessInstanceActive(processInstance);

    countDownListener.waitTillCompleted();
    assertProcessInstanceActive(processInstance.getId(), ksession);

    ksession.abortProcessInstance(processInstance.getId());

    assertProcessInstanceAborted(processInstance.getId(), ksession);
}
 
源代码30 项目: kogito-runtimes   文件: StartEventTest.java
@Test
@Timeout(10)
public void testTimerStartCycleLegacy() throws Exception {
    NodeLeftCountDownProcessEventListener countDownListener = new NodeLeftCountDownProcessEventListener("StartProcess", 2);
    KieBase kbase = createKnowledgeBase("BPMN2-TimerStartCycleLegacy.bpmn2");
    ksession = createKnowledgeSession(kbase);
    ksession.addEventListener(countDownListener);
    final List<String> list = new ArrayList<>();
    ksession.addEventListener(new DefaultProcessEventListener() {
        public void beforeProcessStarted(ProcessStartedEvent event) {
            list.add(event.getProcessInstance().getId());
        }
    });
    logger.debug("About to start ###### " + new Date());

    assertThat(list.size()).isEqualTo(0);
    // then wait 5 times 5oo ms as that is period configured on the process
    countDownListener.waitTillCompleted();
    ksession.dispose();
    assertThat(getNumberOfProcessInstances("Minimal")).isEqualTo(2);

}
 
源代码评论
动弹
沙发等你来抢
 类所在包
 同包方法