调整pom

hos-arbiter/pom.xml

@@ -68,4 +68,23 @@
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <mainClass>com.yihu.hos.arbiter.HosArbiterApplication</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

hos-arbiter/src/main/resources/application.yml

@@ -22,7 +22,7 @@ arbiter:
  timer:
    period: 10000
  central:
    url: localhost:9020
    url: 172.19.103.57:9020
  tenant:
    name: jkzl
@@ -45,9 +45,7 @@ arbiter:
  timer:
    period: 10000
  central:
    url: 172.17.110.202:15555
  terminal:
    url: 172.17.110.202:15555
    url: 172.19.103.57:9020
  tenant:
    name: jkzl
  mycat:
@@ -71,6 +69,6 @@ arbiter:
  timer:
      period: 10000
  central:
    url: 192.168.131.38:15555
    url: 172.19.103.57:9020
  tenant:
    name: yichang

hos-arbiter/src/test/java/com/yihu/hos/arbiter/services/ProxyServiceTest.java

@@ -1,6 +1,9 @@
package com.yihu.hos.arbiter.services;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.TestComponent;
import org.zbus.broker.ZbusBroker;
import org.zbus.mq.Producer;
import org.zbus.net.http.Message;
@@ -9,10 +12,13 @@ import org.zbus.net.http.Message;
 * @author Airhead
 * @since 2016/12/22.
 */
@SpringBootTest
public class ProxyServiceTest {
    @Autowired
    private ZbusBroker zbusBroker;
    @Test
    public void proxy() throws Exception {
        Producer producer = new Producer(new ZbusBroker("192.168.131.38:15555"), "RemoteControl");
        Producer producer = new Producer(zbusBroker, "RemoteControl");
        producer.createMQ();//确定为创建消息队列需要显示调用
        Message msg = new Message();
        msg.setBody("hello world"); //消息体底层是byte[]

hos-broker/pom.xml

@@ -129,5 +129,22 @@
        </dependency>
        <!-- camel end -->
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <mainClass>com.yihu.hos.broker.HosBrokerApplication</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

pom.xml

@@ -186,4 +186,23 @@
        </dependency>
        <!-- swagger end -->
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <mainClass>com.yihu.hos.ESBApplication</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>