AWS CC连接中心参考指南

ActiveMQ - 连接消息服务

ActiveMQ是Apache下的开源消息中间件（https://activemq.apache.org/），ActiveMQ Connector为上层应用场景提供统一的ActiveMQ服务访问和管理。

主要功能

支持ActiveMQ 5.16.0版的消息队列服务
提供CCAPI封装，方便开发者使用
提供ActiveMQ Producer(向ActiveMQ发送消息)的流程编排服务(Service Task)
支持CC环境变量
支持SLA服务质量监控和告警通知，提供全局requestId
提供访问日志开关

特别说明

使用该应用要求AWS PaaS平台许可支持CC服务
使用该应用要求AWS PaaS平台版本不低于6.4.1

1.配置

项	说明
名称	ActiveMQ适配器的名称
代理URL	格式：tcp://39.106.193.36:61616，支持@公式，如@env(xxx)可获取环境中相应变量值
用户名	用户名，支持@公式，如@env(xxx)可获取环境中相应变量值
密码	密码，支持@公式，如@env(xxx)可获取环境中相应变量值
描述	适配器描述信息

2.调用

由开发者在Java代码中调用ActiveMQ服务。

获取模型ID

在CC连接列表中可获取适配器模型ID。

API代码示例

在访问前，我们假设已创建了一个CC ActiveMQ技术适配器，其分配的模型Id为00000000


import com.actionsoft.bpms.bpmn.engine.core.delegate.ProcessExecutionContext;
import com.actionsoft.bpms.bpmn.engine.listener.ExecuteListener;
import com.actionsoft.sdk.local.SDK;
import com.actionsoft.sdk.local.api.cc.JmsAPI;
import com.actionsoft.sdk.local.api.cc.jms.MessageCreator;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

/**
 * 需要在开发环境中引入AWS PaaS平台以下目录下所有jar包：
 * bin/lib目录下
 * bin/jdbc目录下
 * apps/install/com.actionsoft.apps.cc.connector.activemq/lib目录下
 */
public class JMSAPITest  extends ExecuteListener {
    @Override
    public void execute(ProcessExecutionContext processExecutionContext) throws Exception {
       //获得一个ActiveMQ对象
        JmsAPI jmsAPI =  SDK.getCCAPI().getJMSAPI("00000000");

        // mytest1
        jmsAPI.sDefaultDestination("mytest1");
        jmsAPI.send(new MessageCreator() {  //发送

            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage txt = session.createTextMessage();
                txt.setText("hello");
                return txt;
            }

        });

        jmsAPI.receive("mytest1");  //接收，先有发送，才能有接收



        //mytest2
        jmsAPI.send("mytest2", new MessageCreator() {
            @Override
            public Message createMessage(Session arg0) throws JMSException {
                TextMessage ms=arg0.createTextMessage();
                ms.setText("hello  test2");
                return ms;
            }
        });

        TextMessage msg=(TextMessage)jmsAPI.receive("mytest2");
        System.out.println("##############"+msg.getText());


        //test3
        jmsAPI.sendAndReceive("这是默认",new MessageCreator() {
            @Override
            public Message createMessage(Session arg0) throws JMSException {
                Message ms = arg0.createMessage();
                ms.setJMSMessageID("这是一条消息");
                return ms;
            }
        });

        //....
    }
}

ActiveMQAPI JavaDOC https://docs.awspaas.com/api/aws-api-javadoc/com/actionsoft/sdk/local/api/cc/JmsAPI.html

3.流程编排服务

该应用提供ActiveMQ Producer(向ActiveMQ发送消息)的流程服务(Service Task)。

配置

操作步骤：

创建一个流程模型
拖动一个系统任务至画布
配置系统任务，服务类型为流程服务，选择该流程服务，配置相关信息
完成流程模型的正确设计，创建流程实例，到任务到达系统任务时，即可发送消息

4.日志

当连接器开启记录访问请求到审计日志和记录返回结果到文件日志开关后，调用JmsAPI相关方法时，可记录日志，具体哪些方法会记录日志，请参见javadoc JmsAPI说明。

记录访问请求到审计日志

开启后，将访问请求记录到审计日志，该日志存储在AWS PaaS平台SYS_AUDIT_LOG表中，可在日志页进行查看。

记录返回结果到文件日志

开启后，将请求数据和返回结果记录到文件日志，该日志存储在AWS PaaS平台%AWS_HOME%/logs/目录下，默认每个文件日志最大为20M，最多存储20个文件，超出将自动清除最早日期文件。 log文件个数及单文件最大值可在%AWS_HOME%/bin/conf/aws-log4j.xml文件中配置。