zoukankan      html  css  js  c++  java
  • sydnsis 推送和消费amq消息

    环境是minishift,ubuntu

    1.首先我们要amq上建个账号

    账号会涉及到下面4个文件都在etc目录下

    artemis-roles.properties   broker.xml         login.config
    artemis-users.properties 

    但是这里直接改的账号,下次重启就没有了。

    我用的方法是进pod执行下面的命令创建账号

    进入amq的bin目录

    ./artemis user add --user test --password test --role admin

    2.建queue

    建queue我们使用operator方式

    oc create -f 文件

    文件内容如下

    apiVersion: broker.amq.io/v2alpha2
    kind: ActiveMQArtemisAddress
    metadata:
      name: ex-aaoaddress
    spec:
      addressName: order
      queueName: order
      routingType: anycast

    3.接下来我们进入sydnsis创建接口

    3.1首先我们创建amq连接

    点击create connection

     找到AMQP

     amqp协议,证书检查给禁止调,可以点下面的验证按钮,验证连同性

    接下来点保存就可以

    3.2 创建接口

    接下来我们点integrations

    再点 create integration

    选择timer

     

     选择simple,选1分钟

     再选择 amqp,输入queue名字

    接下来搞 schema,有实力的选择json schema,我选择json实例

    点下一步,看到中间加号没有,点它

     选择data map

     点左边加号,创建一个常量

    接下来作个mapping,就是拉根线,把左边的刚才创建的常量拖到右边

     点下一步,再点发布,输入名字,点保存和发布

     结下里就进入了发布状态,就是在minishift里创建pod

    部署成功之后,我们可以看日志了,以每分钟1个方式向mq写数据

    接下来我们去minishift看看pod问声好

    部署完毕

  • 相关阅读:
    oracle--函数
    分页查询
    行列转置(Oracle)
    手动安装Oracle的Maven依赖
    Windows下安装Oracle拖慢开机速度的解决方法
    kettle将Excel数据导入oracle
    Oracle交易流水号问题
    在32位Centos6.4上安装GraphicsMagick
    Centos版本 32或64位查看命令
    Nginx指令概述
  • 原文地址:https://www.cnblogs.com/caihemm/p/13298105.html
Copyright © 2011-2022 走看看