Java AvailablePortFinder类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.camel.test.AvailablePortFinder类的典型用法代码示例。如果您正苦于以下问题：Java AvailablePortFinder类的具体用法？Java AvailablePortFinder怎么用？Java AvailablePortFinder使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AvailablePortFinder类属于org.apache.camel.test包，在下文中一共展示了AvailablePortFinder类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setup

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Before
public void setup() {
    catalog = new CamelCatalogRest();

    port = AvailablePortFinder.getNextAvailable(9000);

    // setup Apache CXF REST server
    JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
    sf.setResourceClasses(CamelCatalogRest.class);
    sf.setResourceProvider(CamelCatalogRest.class, new SingletonResourceProvider(catalog));
    // to use jackson for json
    sf.setProvider(JacksonJsonProvider.class);
    sf.setAddress("http://localhost:" + port);

    // create and start the CXF server (non blocking)
    server = sf.create();
    server.start();
}

开发者ID:fabric8io，项目名称:django，代码行数:19，代码来源:CamelCatalogRestTest.java

示例2: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            port = AvailablePortFinder.getNextAvailable(8000);

            from("netty:tcp://localhost:" + port + "?textline=true&sync=true&reuseAddress=true&synchronous=false")
                .to("activemq:queue:foo")
                .log("Writing reply ${body}");

            from("activemq:queue:foo")
                .transform(simple("Bye ${body}"));
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:NettyAsyncRequestReplyTest.java

示例3: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            port1 = AvailablePortFinder.getNextAvailable(8000);
            port2 = AvailablePortFinder.getNextAvailable(9000);

            // use jetty as server as it supports sending response as chunked encoding
            from("jetty:http://localhost:" + port1 + "/test")
                .setHeader("Transfer-Encoding", constant("chunked"))
                .transform().simple("Bye ${body}");
            
            // set up a netty http proxy
            from("netty-http:http://localhost:" + port2 + "/test")
                .to("netty-http:http://localhost:" + port1 + "/test?bridgeEndpoint=true&throwExceptionOnFailure=false");
      
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:21，代码来源:NettyHttpClientChunkedResponseTest.java

示例4: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            // enable async consumer to process messages faster
            from("activemq:queue:inbox?asyncConsumer=false")
                .to("jetty:http://0.0.0.0:" + port + "/myapp")
                .to("log:result?groupSize=10", "mock:result");

            from("jetty:http://0.0.0.0:" + port + "/myapp")
                .delay(100)
                .transform(body().prepend("Bye "));
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:19，代码来源:JmsJettyAsyncTest.java

示例5: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        public void configure() {
            from("jetty:http://localhost:" + port + "/test")
                .process(new Processor() {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        String name = exchange.getIn().getHeader("name", String.class);
                        ObjectHelper.notNull(name, "name");

                        name = "org/apache/camel/itest/jetty/" + name;
                        InputStream is = ResourceHelper.resolveMandatoryResourceAsInputStream(exchange.getContext().getClassResolver(), name);
                        String xml = exchange.getContext().getTypeConverter().convertTo(String.class, is);

                        exchange.getOut().setBody(xml);
                        exchange.getOut().setHeader(Exchange.CONTENT_TYPE, "text/plain");
                    }
                });
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:25，代码来源:JettyVelocityTest.java

示例6: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("jetty:http://localhost:" + port + "/beer")
                    .convertBodyTo(String.class)
                    .to("mock:before")
                    .setHeader("beer", constant("Carlsberg"))
                    .to("mock:result")
                    .transform(constant("Bye World"));
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:JettyConstantSetHeaderTest.java

示例7: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        public void configure() {
            restConfiguration().component("jetty").host("localhost").scheme("http").port(port);
            rest("/metadata/profile")
                .get("/{id}").to("direct:profileLookup")
                .post("/tag").to("direct:tag");

            from("direct:profileLookup").transform().constant("Mock profile");
            from("direct:tag").log("${headers}").process(new Processor() {
                @Override
                public void process(Exchange ex) throws Exception {
                    ex.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 303);
                    ex.getOut().setHeader("Location", "/metadata/profile/1");
                }
            }).log("${headers}").transform().constant("Redirecting...");
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:23，代码来源:JettyRestRedirectTest.java

示例8: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("jetty:http://localhost:" + port + "/beer")
                    .convertBodyTo(String.class)
                    .to("mock:before")
                    .setHeader("beer", groovy("'Carlsberg'"))
                    .to("mock:result")
                    .transform(groovy("'Bye World'"));
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:JettyGroovySetHeaderTest.java

示例9: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        public void configure() {
            from("jetty:http://localhost:" + port + "/test")
                .process(new Processor() {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        String name = exchange.getIn().getHeader("name", String.class);
                        ObjectHelper.notNull(name, "name");

                        name = "org/apache/camel/itest/jetty/" + name;
                        InputStream is = ResourceHelper.resolveMandatoryResourceAsInputStream(exchange.getContext().getClassResolver(), name);
                        String xml = exchange.getContext().getTypeConverter().convertTo(String.class, is);

                        exchange.getOut().setBody(xml);
                        exchange.getOut().setHeader(Exchange.CONTENT_TYPE, "text/xml");
                    }
                });
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:25，代码来源:JettyXsltTest.java

示例10: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("jetty:http://localhost:" + port + "/beer")
                    .convertBodyTo(String.class)
                    .to("mock:before")
                    .setHeader("beer", simple("Carlsberg"))
                    .to("mock:result")
                    .transform(simple("Bye World"));
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:JettySimpleSetHeaderTest.java

示例11: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    port = AvailablePortFinder.getNextAvailable(8000);

    return new RouteBuilder() {
        public void configure() {
            from("jetty:http://localhost:" + port + "/test")
                .convertBodyTo(String.class)
                .to("log:in")
                .doTry()
                    .to("validator:OptimizationRequest.xsd")
                    .transform(constant("<ok/>"))
                .doCatch(ValidationException.class)
                    .transform(constant("<error/>"))
                .end()
                .to("log:out");
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:20，代码来源:JettyValidatorTest.java

示例12: testFilterArgumentsSetOnEndpoint

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Test
public void testFilterArgumentsSetOnEndpoint() throws Exception {
    // setup
    CometdComponent component = context.getComponent("cometd", CometdComponent.class);
    int port = AvailablePortFinder.getNextAvailable(23500);

    // act
    Endpoint result = component
        .createEndpoint(String.format("cometd://127.0.0.1:%s?crossOriginFilterOn=true&allowedOrigins=%s&filterPath=%s",
             port, ALLOWED_ORIGINS, FILTER_PATH));

    // assert
    assertTrue(result instanceof CometdEndpoint);
    CometdEndpoint cometdEndpoint = (CometdEndpoint)result;
    assertTrue(cometdEndpoint.isCrossOriginFilterOn());
    assertEquals(ALLOWED_ORIGINS, cometdEndpoint.getAllowedOrigins());
    assertEquals(FILTER_PATH, cometdEndpoint.getFilterPath());
}

开发者ID:HydAu，项目名称:Camel，代码行数:19，代码来源:CometdCrossOriginConsumerTest.java

示例13: testCustomName

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Test
public void testCustomName() throws Exception {
    context.start();

    int port = AvailablePortFinder.getNextAvailable(24400);

    Component custom = new HttpComponent();
    context.addComponent("http-foo", custom);
    ServiceHelper.startService(custom);

    String uri = "http-foo://www.somewhere.com:" + port + "?q=Camel";
    Endpoint endpoint = context.getEndpoint(uri);
    assertNotNull(endpoint);
    // the endpoint uri should use the custom component name as scheme
    assertEquals(uri, endpoint.getEndpointUri());

    context.stop();
}

开发者ID:HydAu，项目名称:Camel，代码行数:19，代码来源:HttpCustomComponentNameTest.java

示例14: initPort

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@BeforeClass
public static void initPort() throws Exception {
    File file = new File("target/nettyport.txt");

    if (!file.exists()) {
        // start from somewhere in the 25xxx range
        port = AvailablePortFinder.getNextAvailable(25000);
    } else {
        // read port number from file
        String s = IOConverter.toString(file, null);
        port = Integer.parseInt(s);
        // use next free port
        port = AvailablePortFinder.getNextAvailable(port + 1);
    }

}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:BaseNettyTest.java

示例15: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() {

    mllpClient.setMllpHost("localhost");
    mllpClient.setMllpPort(AvailablePortFinder.getNextAvailable());

    return new RouteBuilder() {
        int connectTimeout = 500;
        int responseTimeout = 5000;

        @Override
        public void configure() throws Exception {
            String routeId = "mllp-test-receiver-route";

            onCompletion()
                    .toF("log:%s?level=INFO&showAll=true", routeId)
                    .log(LoggingLevel.INFO, routeId, "Test route complete");

            fromF("mllp://%s:%d?autoAck=true&connectTimeout=%d&receiveTimeout=%d",
                    mllpClient.getMllpHost(), mllpClient.getMllpPort(), connectTimeout, responseTimeout)
                    .routeId(routeId)
                    .to(result);

        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:27，代码来源:MllpTcpServerConsumerAcknowledgementTest.java

示例16: beforeClass

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@BeforeClass
public static void beforeClass() {
    // start from somewhere in the 23xxx range
    zookeeperPort = AvailablePortFinder.getNextAvailable(23000);
    // find another ports for proxy route test
    karfkaPort = AvailablePortFinder.getNextAvailable(24000);

    embeddedZookeeper = new EmbeddedZookeeper(zookeeperPort);
    List<Integer> kafkaPorts = new ArrayList<Integer>();
    // -1 for any available port
    kafkaPorts.add(karfkaPort);
    embeddedKafkaCluster = new EmbeddedKafkaCluster(embeddedZookeeper.getConnection(), new Properties(), kafkaPorts);
    try {
        embeddedZookeeper.startup();
    } catch (IOException e) {
        e.printStackTrace();
    }
    System.out.println("### Embedded Zookeeper connection: " + embeddedZookeeper.getConnection());
    embeddedKafkaCluster.startup();
    System.out.println("### Embedded Kafka cluster broker list: " + embeddedKafkaCluster.getBrokerList());
}

开发者ID:HydAu，项目名称:Camel，代码行数:22，代码来源:BaseEmbeddedKafkaTest.java

示例17: initPort

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@BeforeClass
public static void initPort() throws Exception {
    File file = new File("target/nettyport.txt");

    if (!file.exists()) {
        // start from somewhere in the 26xxx range
        port = AvailablePortFinder.getNextAvailable(26000);
    } else {
        // read port number from file
        String s = IOConverter.toString(file, null);
        port = Integer.parseInt(s);
        // use next free port
        port = AvailablePortFinder.getNextAvailable(port + 1);
    }

}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:BaseNettyTest.java

示例18: createRouteBuilder

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    return new RouteBuilder() {
        public void configure() throws Exception {
            from("jetty:http://localhost:" + AvailablePortFinder.getNextAvailable() + "/ myapp / myservice")
                .process(new Processor() {
                    public void process(Exchange exchange) throws Exception {
                        String body = exchange.getIn().getBody(String.class);
                        assertNotNull("Body should not be null", body);
                    }
                })
                .transform(constant("OK")).setHeader("Content-Type", constant("text/plain"))
                .to("mock:result");
        }
    };
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:JettyManual.java

示例19: configure

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Override
public void configure() throws Exception {

    // get port number dynamically
    int port = AvailablePortFinder.getNextAvailable();

    // START SNIPPET: consumer_route
    from("restlet:http://localhost:" + port + "/securedOrders?restletMethod=post&restletRealm=#realm").process(new Processor() {
        public void process(Exchange exchange) throws Exception {
            exchange.getOut().setBody(
                    "received [" + exchange.getIn().getBody(String.class)
                    + "] as an order id = "
                    + exchange.getIn().getHeader("id"));
        }
    });
    // END SNIPPET: consumer_route

    // START SNIPPET: producer_route
    // Note: restletMethod and restletRealmRef are stripped 
    // from the query before a request is sent as they are 
    // only processed by Camel.
    from("direct:start-auth").to("restlet:http://localhost:" + port + "/securedOrders?restletMethod=post");
    // END SNIPPET: producer_route
  
}

开发者ID:HydAu，项目名称:Camel，代码行数:26，代码来源:TestRouteBuilder.java

示例20: setup

import org.apache.camel.test.AvailablePortFinder; //导入依赖的package包/类
@Before
public void setup() {
    catalog = new CamelCatalogRest();

    port = AvailablePortFinder.getNextAvailable(9000);

    // setup Apache CXF REST server
    JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
    sf.setResourceClasses(CamelCatalogRest.class);
    sf.setResourceProvider(CamelCatalogRest.class, new SingletonResourceProvider(catalog));

    Swagger2Feature swagger = new Swagger2Feature();
    swagger.setBasePath("/");
    swagger.setScanAllResources(false);
    swagger.setPrettyPrint(true);
    swagger.setSupportSwaggerUi(true);
    swagger.setTitle("Camel Catalog REST Api");
    swagger.setDescription("REST Api for the Camel Catalog");
    swagger.setVersion(catalog.getCatalogVersion());
    swagger.setContact("Apache Camel");
    sf.getFeatures().add(swagger);

    // to use jackson for json
    sf.setProvider(JacksonJsonProvider.class);
    sf.setAddress("http://localhost:" + port);

    // create and start the CXF server (non blocking)
    server = sf.create();
    server.start();
}

开发者ID:fabric8io，项目名称:django，代码行数:31，代码来源:CamelCatalogSwaggerTest.java

注：本文中的org.apache.camel.test.AvailablePortFinder类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Constants类代码示例发布时间：2022-05-22

Java SoyListData类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19190|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9988|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8326|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8696|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8639|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9657|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8624|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7998|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8656|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7535|2022-11-06

客服电话

电子邮件

Java AvailablePortFinder类代码示例

示例1: setup

示例2: createRouteBuilder

示例3: createRouteBuilder

示例4: createRouteBuilder

示例5: createRouteBuilder

示例6: createRouteBuilder

示例7: createRouteBuilder

示例8: createRouteBuilder

示例9: createRouteBuilder

示例10: createRouteBuilder

示例11: createRouteBuilder

示例12: testFilterArgumentsSetOnEndpoint

示例13: testCustomName

示例14: initPort

示例15: createRouteBuilder

示例16: beforeClass

示例17: initPort

示例18: createRouteBuilder

示例19: configure

示例20: setup

请发表评论

全部评论

上一篇：

下一篇：

PacktPublishing/Python-Machine-Learning-

armancodv/building-energy-model-matlab:

鲁东大学一米网:Win7系统USB驱动器RAM的操

Matlab基础 - 白途思

FGRibreau/import-tweets-to-mastodon: How

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053