主页
产品
Red Hat Fuse
7.12
Apache Camel 组件参考
225.6. 带有 sync=true 的示例

225.6. 带有 sync=true 的示例

在下一个示例中，我们有一个比较常见的用例，其中我们在端口 6201 上公开 TCP 服务也会使用 textline codec。但是，这一次我们想要返回响应，因此我们将消费者的 sync 选项设置为 true。

from("mina2:tcp://localhost:" + port2 + "?textline=true&sync=true").process(new Processor() {
    public void process(Exchange exchange) throws Exception {
        String body = exchange.getIn().getBody(String.class);
        exchange.getOut().setBody("Bye " + body);
    }
});

from("mina2:tcp://localhost:" + port2 + "?textline=true&sync=true").process(new Processor() {
    public void process(Exchange exchange) throws Exception {
        String body = exchange.getIn().getBody(String.class);
        exchange.getOut().setBody("Bye " + body);
    }
});

Copy to Clipboard

Toggle word wrap

然后，我们通过发送一些数据并使用 template.requestBody （） 方法检索响应来测试示例。正如我们知道响应是 String，我们将其定向到 String，并可以断言响应是实际上，我们在处理器代码逻辑中动态设置的内容。

String response = (String)template.requestBody("mina2:tcp://localhost:" + port2 + "?textline=true&sync=true", "World");
assertEquals("Bye World", response);

String response = (String)template.requestBody("mina2:tcp://localhost:" + port2 + "?textline=true&sync=true", "World");
assertEquals("Bye World", response);

Copy to Clipboard

Toggle word wrap

返回顶部

225.6. 带有 sync=true 的示例

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links