小编Nit*_*ora的帖子

Spring Data ElasticSearch TransportClient Java配置

有人知道什么是Java Config相当于:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/data/elasticsearch
http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch-1.0.xsd">
    <elasticsearch:transport-client id="client" cluster-nodes="localhost:9300,someip:9300"
/>
</beans>
Run Code Online (Sandbox Code Playgroud)

我特意想nodeBuilder()用来做.

java spring elasticsearch spring-data-elasticsearch

7
推荐指数
1
解决办法
1万
查看次数

Spring AMQP项目有2个队列

我正在开发一个涉及2个队列的项目,并将多个Listeners与它们进行交互.流:

  • 新的HTTP请求到达服务器,然后它被转换为将成为消息的Object
  • 此消息必须以两个队列发布
  • 我有两种类型的监听器,它从每个队列中获取消息,然后我做任何我想做的事情

我一直在阅读,最好的方法是进行扇出交流.这是我的代码:

监听-configuration.xml文件

<!-- CREATE CONNECTION FACTORY -->
<rabbit:connection-factory id="connectionFactory"
    host="localhost" username="guest" password="guest" />

<rabbit:admin connection-factory="connectionFactory" />

<!-- <!-- RABBIT QUEUE'S -->
<rabbit:queue id="trashroute.rabbit.queue" name="trashroute.rabbit.queue" auto-delete="false" auto-startup=false
    durable="true" />
<!-- Webapp Queue -->
<rabbit:queue id="trashroute2.rabbit.queue" name="trashroute2.rabbit.queue" auto-delete="false" auto-startup=false
    durable="true" /> 

<!-- CREATE AN EXCHANGE AND BIND THE QUEUE WITH MY.ROUTINGKEY.* TO THE EXCHANGE -->
<rabbit:fanout-exchange id="myExchange" name="trashroute-exchange">
    <rabbit:bindings>
        <rabbit:binding queue="trashroute.rabbit.queue"></rabbit:binding>
        <rabbit:binding queue="trashroute2.rabbit.queue"></rabbit:binding>
    </rabbit:bindings>
</rabbit:fanout-exchange>

<!-- CREATE THE RABBIT TEMPLATES -->
<rabbit:template connection-factory="connectionFactory" exchange="myExchange" queue="trashroute.rabbit.queue"/>
<rabbit:template connection-factory="connectionFactory" exchange="myExchange" …
Run Code Online (Sandbox Code Playgroud)

rabbitmq spring-amqp

2
推荐指数
1
解决办法
7619
查看次数