Browse Source

broker pom error

huangzhiyong 7 years ago
parent
commit
79872d8fa1

+ 13 - 16
hos-broker/pom.xml

@ -16,19 +16,21 @@
    <name>hos-broker</name>
    <description>ESB服务运行模块</description>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-netflix</artifactId>
                <version>1.2.6.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-netflix</artifactId>
            <version>${spring-cloud-version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>${spring-cloud-version}</version>
        </dependency>
        <!-- spring-boot -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
@ -64,11 +66,6 @@
            <artifactId>slf4j-api</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <!-- sigar -->
        <dependency>
            <groupId>org.fusesource</groupId>

+ 4 - 7
hos-camel2/src/main/java/camel/central/archives/processor/ArchivesService.java

@ -5,13 +5,10 @@ import com.yihu.hos.core.log.LoggerFactory;
import org.springframework.stereotype.Service;
/**
 * Broker原则上具有等同性,这样Arbiter无论选择了哪个Broker能提供的服务都是一样的。
 * 但是因为Broker上还是会运行一些定时的采集任务,这些采集任务如果是多台Broker运行的话,可能会引起数据重复问题。
 * 所以在事件触发时需要做一些策略的调整:
 * 1.实时任务,通知所有的Broker进行更新路由
 * 2.采集任务,只通知其中的一台进行更新路由
 *
 * @created Airhead 2016/8/16.
 * 数据入库
 * @author HZY
 * @vsrsion 1.0
 * Created at 2017/06/26.
 */
@Service("archivesService")
public class ArchivesService {

+ 4 - 2
hos-camel2/src/main/java/camel/central/archives/route/ArchivesMqRouter.java

@ -11,8 +11,10 @@ import org.springframework.stereotype.Component;
import javax.jms.ConnectionFactory;
/**
 *  档案入库流程
 * @created Airhead 2016/8/1.
 *  档案入库-消息接收服务
 * @author HZY
 * @vsrsion 1.0
 * Created at 2017/3/13.
 */
@Component
public class ArchivesMqRouter extends RouteBuilder {

+ 1 - 1
hos-parent/pom.xml

@ -12,7 +12,7 @@
    <properties>
        <hos-version>1.3.0</hos-version>
        <spring-boot-version>1.4.5.RELEASE</spring-boot-version>
        <spring-cloud-version>1.2.6.RELEASE</spring-cloud-version>
        <camel-version>2.18.3</camel-version>
        <cxf-version>3.1.9</cxf-version>
        <hawtio-version>1.5.0</hawtio-version>