XBean XML 参考 4.1

使用 ActiveMQ Classic > Xml 参考 > XBean XML 参考 4.1

按类型列出的元素

org.apache.activemq.network.jms.InboundQueueBridge 类型实现

<inboundQueueBridge>

创建一个入站队列桥接器

org.apache.activemq.broker.BrokerService 类型实现

<broker>

一个 ActiveMQ Classic 消息代理,它包含多个传输连接器、网络连接器和持久化适配器

org.apache.activemq.broker.BrokerPlugin 类型实现

<authorizationPlugin>

一个授权插件,在对目标执行每个操作时,都会根据授权映射进行检查

<connectionDotFilePlugin>

一个创建 DOT 文件的插件,该插件会创建一个显示当前连接的 DOT 文件

<destinationDotFilePlugin>

一个创建 DOT 文件的插件,该插件会创建一个显示当前主题和队列层次结构的 DOT 文件。

<jaasAuthenticationPlugin>

提供基于 JAAS 的身份验证插件

<loggingBrokerPlugin>

一个简单的代理拦截器,允许您启用/禁用日志记录。

<simpleAuthenticationPlugin>

提供一个简单的身份验证插件,使用用户密码映射和用户组映射进行配置

org.apache.activemq.store.jdbc.JDBCAdapter 类型实现

<blobJDBCAdapter>

该 JDBCAdapter 使用 getBlob()/setBlob() 操作插入和提取 BLOB 数据。这有点复杂,因为要插入一个 blob,您需要执行以下操作:1:插入空 blob。2:选择 blob。3:最后使用数据值更新 blob。使用该适配器的数据库/JDBC 驱动程序为

<bytesJDBCAdapter>

该 JDBCAdapter 使用 setBytes()/getBytes() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

<db2JDBCAdapter>

<defaultJDBCAdapter>

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

<imageBasedJDBCAdaptor>

提供 JDBCAdapter,因为它使用 IMAGE 数据类型来保存二进制数据。使用该适配器的数据库/JDBC 驱动程序为

  • Sybase
  • MS SQL

<oracleJDBCAdapter>

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

<streamJDBCAdapter>

该 JDBCAdapter 使用 setBinaryStream()/getBinaryStream() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

  • Axion

org.apache.activemq.broker.region.virtual.VirtualDestination 类型实现

<compositeQueue>

表示一个虚拟队列,它转发到多个其他目标。

<compositeTopic>

表示一个虚拟主题,它转发到多个其他目标。

<virtualTopic>

使用前缀和后缀创建 虚拟主题。虚拟目标创建一个通配符,然后使用该通配符查找所有匹配的活动队列订阅。

org.apache.activemq.broker.region.policy.PolicyMap 类型实现

<policyMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。

org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy 类型实现

<constantPendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 被配置为对所有订阅使用常量值。

<prefetchRatePendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 将最大待处理消息限制值设置为订阅预取限制的倍数。

org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy 类型实现

<fixedCountSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

<fixedSizedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将在 RAM 中保留固定数量的内存以用于消息历史记录,这些消息历史记录将按时间顺序逐出。

<lastImageSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

<noSubscriptionRecoveryPolicy>

这是默认主题恢复策略,它不会恢复任何消息。

<queryBasedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将执行用户特定的查询机制以加载他们可能错过的任何消息。

<timedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将在内存中保留一个定时消息缓冲区,并使用它来恢复新的订阅。

org.apache.activemq.store.jdbc.Statements 类型实现

<statements>

org.apache.activemq.broker.jmx.ManagementContext 类型实现

<managementContext>

Flow 在 NMR 中提供不同的分派策略

org.apache.activemq.store.PersistenceAdapterFactory 类型实现

<journaledJDBC>

使用日志和 JDBC 创建默认持久化模型

org.apache.activemq.security.AuthorizationEntry 类型实现

<authorizationEntry>

表示 {@link DefaultAuthorizationMap} 中的一个条目,用于将用户角色的不同操作(读取、写入、管理)分配给特定目标或目标的层次通配符区域。

org.apache.activemq.broker.region.policy.DeadLetterStrategy 类型实现

<individualDeadLetterStrategy>

一个 {@link DeadLetterStrategy},其中每个目标都有使用主题命名层次结构的自己的独立 DLQ。

<sharedDeadLetterStrategy>

一个 {@link DeadLetterStrategy} 的默认实现,它使用一个常量目标。

javax.jms.Topic 类型实现

<topic>

一个 ActiveMQ Classic 主题目标

org.apache.activemq.store.PersistenceAdapter 类型实现

<jdbcPersistenceAdapter>

一个使用 JDBC 进行持久化存储的 {@link PersistenceAdapter} 实现。该持久化适配器将正确记住准备好的 XA 事务,但它不会跟踪本地事务提交,以便对消息存储执行的操作作为单个 uow 执行。

<journalPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

<kahaPersistenceAdapter>

<memoryPersistenceAdapter>

<quickJournalPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

<rapidPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

org.apache.activemq.broker.region.policy.PolicyEntry 类型实现

<policyEntry>

表示 {@link PolicyMap} 中的一个条目,用于将策略分配给特定目标或目标的层次通配符区域。

org.apache.activemq.network.DemandForwardingBridgeSupport 类型实现

<compositeDemandForwardingBridge>

一个按需转发桥接器,它与多播式传输一起工作,其中单个传输可以与多个远程代理进行通信

<demandForwardingBridge>

根据需要将消息从本地代理转发到远程代理。

org.apache.activemq.network.jms.OutboundQueueBridge 类型实现

<outboundQueueBridge>

创建一个出站队列桥接器

org.apache.activemq.memory.UsageManager 类型实现

<usageManager>

用于跟踪某个东西的使用量,以便可以控制生产性工作集使用量。主要用例是管理内存使用量。

org.apache.activemq.store.jdbc.JDBCPersistenceAdapter 类型实现

<jdbcPersistenceAdapter>

一个使用 JDBC 进行持久化存储的 {@link PersistenceAdapter} 实现。该持久化适配器将正确记住准备好的 XA 事务,但它不会跟踪本地事务提交,以便对消息存储执行的操作作为单个 uow 执行。

org.apache.activemq.command.ActiveMQDestination 类型实现

<queue>

一个 ActiveMQ Classic 队列目标

<topic>

一个 ActiveMQ Classic 主题目标

org.apache.activemq.network.jms.InboundTopicBridge 类型实现

<inboundTopicBridge>

创建一个入站主题桥接器

org.apache.activemq.network.jms.JmsConnector 类型实现

<jmsQueueConnector>

与其他 JMS 队列提供程序的桥接器

<jmsTopicConnector>

与其他 JMS 主题提供程序的桥接器

org.apache.activemq.security.AuthorizationMap 类型实现

<authorizationMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。映射中的每个条目都代表每个操作的授权 ACL。

<simpleAuthorizationMap>

一个 AuthorizationMap,它使用每个操作的单个 DestinationMaps 进行配置。

org.apache.activemq.broker.region.policy.DispatchPolicy 类型实现

<roundRobinDispatchPolicy>

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<simpleDispatchPolicy>

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<strictOrderDispatchPolicy>

分派策略,使每个订阅按相同顺序看到消息。

javax.jms.Queue 类型实现

<queue>

一个 ActiveMQ Classic 队列目标

org.apache.activemq.broker.region.policy.MessageEvictionStrategy 类型实现

<oldestMessageEvictionStrategy>

一种逐出策略,它首先逐出最旧的消息(这是默认设置)。

<oldestMessageWithLowestPriorityEvictionStrategy>

一种逐出策略,它首先逐出优先级最低的最旧的消息。

org.apache.activemq.network.jms.JmsMesageConvertor 类型实现

<simpleJmsMessageConvertor>

将消息从一个 JMS 转换为另一个 JMS

org.apache.activemq.broker.region.DestinationInterceptor 类型实现

<virtualDestinationInterceptor>

实现 虚拟主题

org.apache.activemq.network.jms.OutboundTopicBridge 类型实现

<outboundTopicBridge>

创建一个出站主题桥接器

org.apache.activemq.filter.DestinationMap 类型实现

<authorizationMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。映射中的每个条目都代表每个操作的授权 ACL。

<policyMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。

<authorizationEntry> 元素

表示 {@link DefaultAuthorizationMap} 中的一个条目,用于将用户角色的不同操作(读取、写入、管理)分配给特定目标或目标的层次通配符区域。

属性

属性名称

类型

描述

admin

java.lang.String

adminACLs

java.util.Set

destination

org.apache.activemq.command.ActiveMQDestination

queue

java.lang.String

一个帮助方法,用于从配置文件设置目标

read

java.lang.String

readACLs

java.util.Set

topic

java.lang.String

一个帮助方法,用于从配置文件设置目标

write

java.lang.String

writeACLs

java.util.Set

<authorizationMap> 元素

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。映射中的每个条目都代表每个操作的授权 ACL。

属性

属性名称

类型

描述

authorizationEntries

(java.lang.Object)*

设置授权映射上的各个条目

defaultEntry

org.apache.activemq.security.AuthorizationEntry

entries

(java.lang.Object)*

一个帮助方法,允许目标映射从依赖项注入框架(如 Spring)进行填充

<authorizationPlugin> 元素

一个授权插件,在对目标执行每个操作时,都会根据授权映射进行检查

属性

属性名称

类型

描述

map

org.apache.activemq.security.AuthorizationMap

<axionJDBCAdapter> 元素

Axion 特定适配器。Axion 似乎不支持 ALTER 语句或子选择。这意味着:- 我们无法自动升级我们在推出 ActiveMQ Classic 的新版本时使用的架构 - 我们无法删除已被所有消费者确认的持久订阅消息。

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<blobJDBCAdapter> 元素

该 JDBCAdapter 使用 getBlob()/setBlob() 操作插入和提取 BLOB 数据。这有点复杂,因为要插入一个 blob,您需要执行以下操作:1:插入空 blob。2:选择 blob。3:最后使用数据值更新 blob。使用该适配器的数据库/JDBC 驱动程序为

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<broker> 元素

一个 ActiveMQ Classic 消息代理,它包含多个传输连接器、网络连接器和持久化适配器

属性

属性名称

类型

描述

adminView

org.apache.activemq.broker.jmx.BrokerView

返回代理的管理视图;用于创建和销毁资源(如队列和主题)。请注意,如果 JMX 已禁用,则此方法将返回 null。

advisorySupport

boolean

允许出于性能原因禁用对咨询消息的支持。

brokerName

java.lang.String

设置此代理的名称;该名称在网络中必须是唯一的

brokerObjectName

javax.management.ObjectName

设置此代理的 JMX ObjectName

dataDirectory

java.io.File

设置 JDBC 和 Journal 持久性适配器默认存储数据文件的目录。

deleteAllMessagesOnStartup

boolean

设置启动时是否删除所有消息 - 主要仅对测试有用。

destinationInterceptors

(org.apache.activemq.broker.region.DestinationInterceptor)*

设置要使用的目标拦截器

destinationPolicy

org.apache.activemq.broker.region.policy.PolicyMap

设置可用于精确目标或目标通配符区域的目标特定策略。

destinations

(org.apache.activemq.command.ActiveMQDestination)*

设置启动时应加载/创建的目标

jmsBridgeConnectors

(org.apache.activemq.network.jms.JmsConnector)*

keepDurableSubsActive

boolean

managementContext

org.apache.activemq.broker.jmx.ManagementContext

masterConnectorURI

java.lang.String

memoryManager

org.apache.activemq.memory.UsageManager

messageAuthorizationPolicy

org.apache.activemq.security.MessageAuthorizationPolicy

设置用于决定当前连接是否有权消费给定消息的策略

networkConnectorURIs

(java.lang.String)*

networkConnectors

(java.lang.Object)*

设置此代理将用于连接到联合网络中其他代理的网络连接器

persistenceAdapter

org.apache.activemq.store.PersistenceAdapter

设置要为此代理使用的持久性适配器实现

persistenceFactory

org.apache.activemq.store.PersistenceAdapterFactory

persistent

boolean

设置是否启用或禁用持久性。

plugins

(org.apache.activemq.broker.BrokerPlugin)*

设置要安装的多个代理插件,例如用于安全身份验证或授权

populateJMSXUserID

boolean

设置代理是否应填充 JMSXUserID 标头。

proxyConnectors

(java.lang.Object)*

设置此代理将用于连接到联合网络中其他代理的网络连接器

shutdownOnMasterFailure

boolean

start

boolean

设置代理是否应与其定义在其中的 ApplicationContext 一起启动。通常您希望代理与 ApplicationContext 一起启动,但有时在使用 JUnit 测试时,您可能希望自己明确启动和停止代理。

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

transportConnectorURIs

(java.lang.String)*

transportConnectors

(java.lang.Object)*

设置此代理将侦听以接收新客户端的传输连接器

useJmx

boolean

设置代理的服务是否应暴露到 JMX 中。

useLoggingForShutdownErrors

boolean

设置我们是否应该在报告关闭代理时发生的错误时使用 commons-logging

useShutdownHook

boolean

设置我们是否应该使用关闭处理程序,以便在 JVM 终止时干净地关闭代理。建议您保持启用状态。

useVirtualTopics

boolean

设置是否应默认支持 虚拟主题,即使它们尚未明确配置。

vmConnectorURI

java.net.URI

<bytesJDBCAdapter> 元素

该 JDBCAdapter 使用 setBytes()/getBytes() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<compositeDemandForwardingBridge> 元素

一个按需转发桥接器,它与多播式传输一起工作,其中单个传输可以与多个远程代理进行通信

属性

属性名称

类型

描述

decreaseNetworkConsumerPriority

boolean

dispatchAsync

boolean

durableDestinations

(org.apache.activemq.command.ActiveMQDestination)*

dynamicallyIncludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

excludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

localBroker

org.apache.activemq.transport.Transport

localBrokerName

java.lang.String

name

java.lang.String

networkTTL

int

password

java.lang.String

prefetchSize

int

remoteBroker

org.apache.activemq.transport.Transport

staticallyIncludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

userName

java.lang.String

<compositeQueue> 元素

表示一个虚拟队列,它转发到多个其他目标。

属性

属性名称

类型

描述

copyMessage

boolean

设置是否将消息的副本发送到每个目标。默认为 true,以便将转发目标设置为消息的目标

forwardOnly

boolean

设置虚拟目标是仅转发(因此没有物理队列与虚拟队列匹配)还是也有一个与之同名的物理队列。

forwardTo

java.util.Collection

设置要转发到的目标列表

name

java.lang.String

设置此复合目标的名称

<compositeTopic> 元素

表示一个虚拟主题,它转发到多个其他目标。

属性

属性名称

类型

描述

copyMessage

boolean

设置是否将消息的副本发送到每个目标。默认为 true,以便将转发目标设置为消息的目标

forwardOnly

boolean

设置虚拟目标是仅转发(因此没有物理队列与虚拟队列匹配)还是也有一个与之同名的物理队列。

forwardTo

java.util.Collection

设置要转发到的目标列表

name

java.lang.String

设置此复合目标的名称

<connectionDotFilePlugin> 元素

一个创建 DOT 文件的插件,该插件会创建一个显示当前连接的 DOT 文件

属性

属性名称

类型

描述

file

java.lang.String

设置要创建目标图的目标文件名

<constantPendingMessageLimitStrategy> 元素

此 PendingMessageLimitStrategy 被配置为对所有订阅使用常量值。

属性

属性名称

类型

描述

limit

int

<db2JDBCAdapter> 元素

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<defaultJDBCAdapter> 元素

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<demandForwardingBridge> 元素

根据需要将消息从本地代理转发到远程代理。

属性

属性名称

类型

描述

decreaseNetworkConsumerPriority

boolean

dispatchAsync

boolean

durableDestinations

(org.apache.activemq.command.ActiveMQDestination)*

dynamicallyIncludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

excludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

localBroker

org.apache.activemq.transport.Transport

localBrokerName

java.lang.String

name

java.lang.String

networkTTL

int

password

java.lang.String

prefetchSize

int

remoteBroker

org.apache.activemq.transport.Transport

staticallyIncludedDestinations

(org.apache.activemq.command.ActiveMQDestination)*

userName

java.lang.String

<destinationDotFilePlugin> 元素

一个创建 DOT 文件的插件,该插件会创建一个显示当前主题和队列层次结构的 DOT 文件。

属性

属性名称

类型

描述

file

java.lang.String

设置要创建目标图的目标文件名

<destinationEntry> 元素

DestinationMap 中的默认条目,它包含单个值。

属性

属性名称

类型

描述

destination

org.apache.activemq.command.ActiveMQDestination

queue

java.lang.String

一个帮助方法,用于从配置文件设置目标

topic

java.lang.String

一个帮助方法,用于从配置文件设置目标

value

java.lang.Object

<fixedCountSubscriptionRecoveryPolicy> 元素

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

属性

属性名称

类型

描述

maximumSize

int

设置此目标在 RAM 中保留的消息的最大数量

<fixedSizedSubscriptionRecoveryPolicy> 元素

此 {@link SubscriptionRecoveryPolicy} 的实现将在 RAM 中保留固定数量的内存以用于消息历史记录,这些消息历史记录将按时间顺序逐出。

属性

属性名称

类型

描述

buffer

org.apache.activemq.memory.list.MessageList

maximumSize

int

设置此缓冲区在 RAM 中可容纳的 RAM 最大容量(以字节为单位)

useSharedBuffer

boolean

<forwardingBridge> 元素

将来自本地代理的所有消息转发到远程代理。

属性

属性名称

类型

描述

clientId

java.lang.String

destinationFilter

java.lang.String

dispatchAsync

boolean

localBroker

org.apache.activemq.transport.Transport

prefetchSize

int

remoteBroker

org.apache.activemq.transport.Transport

<imageBasedJDBCAdaptor> 元素

提供 JDBCAdapter,因为它使用 IMAGE 数据类型来保存二进制数据。使用该适配器的数据库/JDBC 驱动程序为

  • Sybase
  • MS SQL

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<inboundQueueBridge> 元素

创建一个入站队列桥接器

属性

属性名称

类型

描述

consumer

javax.jms.MessageConsumer

consumerConnection

javax.jms.QueueConnection

consumerQueue

javax.jms.Queue

doHandleReplyTo

boolean

inboundQueueName

java.lang.String

jmsConnector

org.apache.activemq.network.jms.JmsConnector

jmsMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

producerConnection

javax.jms.QueueConnection

producerQueue

javax.jms.Queue

selector

java.lang.String

<inboundTopicBridge> 元素

创建一个入站主题桥接器

属性

属性名称

类型

描述

consumer

javax.jms.MessageConsumer

consumerConnection

javax.jms.TopicConnection

consumerName

java.lang.String

consumerTopic

javax.jms.Topic

doHandleReplyTo

boolean

inboundTopicName

java.lang.String

jmsConnector

org.apache.activemq.network.jms.JmsConnector

jmsMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

producerConnection

javax.jms.TopicConnection

producerTopic

javax.jms.Topic

selector

java.lang.String

<individualDeadLetterStrategy> 元素

一个 {@link DeadLetterStrategy},其中每个目标都有使用主题命名层次结构的自己的独立 DLQ。

属性

属性名称

类型

描述

queuePrefix

java.lang.String

设置用于所有队列消息的死信队列的前缀

topicPrefix

java.lang.String

设置用于所有主题消息的死信队列的前缀

useQueueForQueueMessages

boolean

设置应使用队列还是主题来处理发送到 DLQ 的队列消息。默认使用队列

useQueueForTopicMessages

boolean

设置应使用队列还是主题来处理发送到 DLQ 的主题消息。默认使用队列

<informixJDBCAdapter> 元素

用于 Informix 数据库的 JDBC 适配器。由于 Informix 数据库限制复合主键的长度,因此容器名称字段和订阅 ID字段的长度必须缩短至 150 个字符。因此,请确保容器名称和订阅 ID 的名称长度不超过 150 个字符。

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<jaasAuthenticationPlugin> 元素

提供基于 JAAS 的身份验证插件

属性

属性名称

类型

描述

configuration

java.lang.String

设置使用的 JAAS 配置域名称

discoverLoginConfig

boolean

启用或禁用 JAAS 自动发现 login.config 文件以进行初始化。此标志默认启用,因此如果未定义java.security.auth.login.config系统属性,则将其设置为类路径上login.config文件的路径。

<jdbcPersistenceAdapter> 元素

一个使用 JDBC 进行持久化存储的 {@link PersistenceAdapter} 实现。该持久化适配器将正确记住准备好的 XA 事务,但它不会跟踪本地事务提交,以便对消息存储执行的操作作为单个 uow 执行。

属性

属性名称

类型

描述

adapter

org.apache.activemq.store.jdbc.JDBCAdapter

brokerService

org.apache.activemq.broker.BrokerService

cleanupPeriod

int

dataDirectory

java.lang.String

dataDirectoryFile

java.io.File

dataSource

javax.sql.DataSource

databaseLocker

org.apache.activemq.store.jdbc.DatabaseLocker

设置要用于在启动时锁定数据库的数据库锁定策略

ds

javax.sql.DataSource

scheduledThreadPoolExecutor

edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor

statements

org.apache.activemq.store.jdbc.Statements

usageManager

org.apache.activemq.memory.UsageManager

useDatabaseLock

boolean

useExternalMessageReferences

boolean

wireFormat

org.apache.activeio.command.WireFormat

<jmsQueueConnector> 元素

与其他 JMS 队列提供程序的桥接器

属性

属性名称

类型

描述

brokerService

org.apache.activemq.broker.BrokerService

配置本地连接的一种方法 - 当连接器嵌入时,BrokerService 会调用它

inboundMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

inboundQueueBridges

(org.apache.activemq.network.jms.InboundQueueBridge)*

jndiLocalTemplate

org.springframework.jndi.JndiTemplate

jndiOutboundTemplate

org.springframework.jndi.JndiTemplate

localConnectionFactoryName

java.lang.String

localPassword

java.lang.String

localQueueConnection

javax.jms.QueueConnection

localQueueConnectionFactory

javax.jms.QueueConnectionFactory

localUsername

java.lang.String

name

java.lang.String

outboundMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

outboundPassword

java.lang.String

outboundQueueBridges

(org.apache.activemq.network.jms.OutboundQueueBridge)*

outboundQueueConnection

javax.jms.QueueConnection

outboundQueueConnectionFactory

javax.jms.QueueConnectionFactory

outboundQueueConnectionFactoryName

java.lang.String

outboundUsername

java.lang.String

replyToDestinationCacheSize

int

<jmsTopicConnector> 元素

与其他 JMS 主题提供程序的桥接器

属性

属性名称

类型

描述

brokerService

org.apache.activemq.broker.BrokerService

配置本地连接的一种方法 - 当连接器嵌入时,BrokerService 会调用它

inboundMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

inboundTopicBridges

(org.apache.activemq.network.jms.InboundTopicBridge)*

jndiLocalTemplate

org.springframework.jndi.JndiTemplate

jndiOutboundTemplate

org.springframework.jndi.JndiTemplate

localConnectionFactoryName

java.lang.String

localPassword

java.lang.String

localTopicConnection

javax.jms.TopicConnection

localTopicConnectionFactory

javax.jms.TopicConnectionFactory

localUsername

java.lang.String

name

java.lang.String

outboundMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

outboundPassword

java.lang.String

outboundTopicBridges

(org.apache.activemq.network.jms.OutboundTopicBridge)*

outboundTopicConnection

javax.jms.TopicConnection

outboundTopicConnectionFactory

javax.jms.TopicConnectionFactory

outboundTopicConnectionFactoryName

java.lang.String

outboundUsername

java.lang.String

replyToDestinationCacheSize

int

<journalPersistenceAdapter> 元素

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

属性

属性名称

类型

描述

journal

org.apache.activeio.journal.Journal

longTermPersistence

org.apache.activemq.store.PersistenceAdapter

maxCheckpointMessageAddSize

int

maxCheckpointWorkers

int

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

usageManager

org.apache.activemq.memory.UsageManager

useExternalMessageReferences

boolean

<journaledJDBC> 元素

使用日志和 JDBC 创建默认持久化模型

属性

属性名称

类型

描述

adapter

org.apache.activemq.store.jdbc.JDBCAdapter

dataDirectory

java.lang.String

dataDirectoryFile

java.io.File

dataSource

javax.sql.DataSource

jdbcAdapter

org.apache.activemq.store.jdbc.JDBCPersistenceAdapter

journal

org.apache.activeio.journal.Journal

journalArchiveDirectory

java.io.File

journalLogFileSize

int

journalLogFiles

int

statements

org.apache.activemq.store.jdbc.Statements

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

useJournal

boolean

useQuickJournal

boolean

<kahaPersistenceAdapter> 元素

属性

属性名称

类型

描述

dir

java.io.File

usageManager

org.apache.activemq.memory.UsageManager

useExternalMessageReferences

boolean

<lastImageSubscriptionRecoveryPolicy> 元素

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

<loggingBrokerPlugin> 元素

一个简单的代理拦截器,允许您启用/禁用日志记录。

属性

属性名称

类型

描述

ackLog

org.apache.commons.logging.Log

adminConnectionContext

org.apache.activemq.broker.ConnectionContext

log

org.apache.commons.logging.Log

next

org.apache.activemq.broker.Broker

sendLog

org.apache.commons.logging.Log

<managementContext> 元素

Flow 在 NMR 中提供不同的分派策略

属性

属性名称

类型

描述

MBeanServer

javax.management.MBeanServer

获取 MBeanServer

connectorPath

java.lang.String

connectorPort

int

createConnector

boolean

createMBeanServer

boolean

findTigerMbeanServer

boolean

启用/禁用搜索 Java 5 平台 MBeanServer

jmxDomainName

java.lang.String

server

javax.management.MBeanServer

useMBeanServer

boolean

<memoryPersistenceAdapter> 元素

属性

属性名称

类型

描述

usageManager

org.apache.activemq.memory.UsageManager

useExternalMessageReferences

boolean

<multicastNetworkConnector> 元素

一个网络连接器,它使用某种多播式传输来与单个逻辑 {@link Transport} 实例上的多个潜在远程代理进行通信,例如在使用多播时。此实现完全不依赖于多播;任何其他基于组的传输都可以使用。

属性

属性名称

类型

描述

bridge

org.apache.activemq.network.DemandForwardingBridgeSupport

brokerName

java.lang.String

conduitSubscriptions

boolean

connectionFilter

org.apache.activemq.network.ConnectionFilter

decreaseNetworkConsumerPriority

boolean

dispatchAsync

boolean

durableDestinations

java.util.Set

dynamicOnly

boolean

dynamicallyIncludedDestinations

(java.lang.Object)*

excludedDestinations

(java.lang.Object)*

localTransport

org.apache.activemq.transport.Transport

localUri

java.net.URI

name

java.lang.String

networkTTL

int

password

java.lang.String

prefetchSize

int

remoteTransport

org.apache.activemq.transport.Transport

设置远程传输实现

remoteURI

java.net.URI

将远程传输 URI 设置为某个组传输,例如 multicast://address:port

staticallyIncludedDestinations

(java.lang.Object)*

userName

java.lang.String

<networkConnector> 元素

一个网络连接器,它使用发现代理来检测可用的远程代理并建立到每个可用远程代理的连接

属性

属性名称

类型

描述

brokerName

java.lang.String

conduitSubscriptions

boolean

connectionFilter

org.apache.activemq.network.ConnectionFilter

decreaseNetworkConsumerPriority

boolean

discoveryAgent

org.apache.activemq.transport.discovery.DiscoveryAgent

discoveryURI

java.net.URI

dispatchAsync

boolean

durableDestinations

java.util.Set

dynamicOnly

boolean

dynamicallyIncludedDestinations

(java.lang.Object)*

excludedDestinations

(java.lang.Object)*

failover

boolean

localUri

java.net.URI

name

java.lang.String

networkTTL

int

password

java.lang.String

prefetchSize

int

staticallyIncludedDestinations

(java.lang.Object)*

uri

java.net.URI

userName

java.lang.String

<noSubscriptionRecoveryPolicy> 元素

这是默认主题恢复策略,它不会恢复任何消息。

<oldestMessageEvictionStrategy> 元素

一种逐出策略,它首先逐出最旧的消息(这是默认设置)。

属性

属性名称

类型

描述

evictExpiredMessagesHighWatermark

int

设置将在其中我们从 RAM 中主动驱逐过期消息的高水位线

<oldestMessageWithLowestPriorityEvictionStrategy> 元素

一种逐出策略,它首先逐出优先级最低的最旧的消息。

属性

属性名称

类型

描述

evictExpiredMessagesHighWatermark

int

设置将在其中我们从 RAM 中主动驱逐过期消息的高水位线

<oracleJDBCAdapter> 元素

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<outboundQueueBridge> 元素

创建一个出站队列桥接器

属性

属性名称

类型

描述

consumer

javax.jms.MessageConsumer

consumerConnection

javax.jms.QueueConnection

consumerQueue

javax.jms.Queue

doHandleReplyTo

boolean

jmsConnector

org.apache.activemq.network.jms.JmsConnector

jmsMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

outboundQueueName

java.lang.String

producerConnection

javax.jms.QueueConnection

producerQueue

javax.jms.Queue

selector

java.lang.String

<outboundTopicBridge> 元素

创建一个出站主题桥接器

属性

属性名称

类型

描述

consumer

javax.jms.MessageConsumer

consumerConnection

javax.jms.TopicConnection

consumerName

java.lang.String

consumerTopic

javax.jms.Topic

doHandleReplyTo

boolean

jmsConnector

org.apache.activemq.network.jms.JmsConnector

jmsMessageConvertor

org.apache.activemq.network.jms.JmsMesageConvertor

outboundTopicName

java.lang.String

producerConnection

javax.jms.TopicConnection

producerTopic

javax.jms.Topic

selector

java.lang.String

<policyEntry> 元素

表示 {@link PolicyMap} 中的一个条目,用于将策略分配给特定目标或目标的层次通配符区域。

属性

属性名称

类型

描述

deadLetterStrategy

org.apache.activemq.broker.region.policy.DeadLetterStrategy

设置用于确定应使用哪个死信队列目标的策略

destination

org.apache.activemq.command.ActiveMQDestination

dispatchPolicy

org.apache.activemq.broker.region.policy.DispatchPolicy

memoryLimit

long

messageEvictionStrategy

org.apache.activemq.broker.region.policy.MessageEvictionStrategy

设置用于决定在慢速消费者需要丢弃消息时驱逐哪个消息的驱逐策略

messageGroupHashBucketCount

int

设置用于消息组功能的哈希桶数量。这仅适用于使用消息组并行处理队列,同时保留单个 JMSXGroupID 标头值之间的顺序。此值设置将使用的哈希桶数量(即,最大可能的并发性)。

pendingMessageLimitStrategy

org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy

设置用于计算消费者允许挂起的最大消息数量(除了它们的预取大小)的策略。一旦达到限制,非持久性主题就可以开始丢弃旧消息。这允许我们继续将消息调度到速度较慢的消费者,同时不会阻塞速度较快的消费者并按时间顺序丢弃最旧的消息。

queue

java.lang.String

一个帮助方法,用于从配置文件设置目标

sendAdvisoryIfNoConsumers

boolean

如果发送非持久性消息且没有活动消费者,则发送咨询消息

subscriptionRecoveryPolicy

org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy

topic

java.lang.String

一个帮助方法,用于从配置文件设置目标

<policyMap> 元素

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。

属性

属性名称

类型

描述

defaultEntry

org.apache.activemq.broker.region.policy.PolicyEntry

entries

(java.lang.Object)*

一个帮助方法,允许目标映射从依赖项注入框架(如 Spring)进行填充

policyEntries

(java.lang.Object)*

设置策略映射上的单个条目

<prefetchRatePendingMessageLimitStrategy> 元素

此 PendingMessageLimitStrategy 将最大待处理消息限制值设置为订阅预取限制的倍数。

属性

属性名称

类型

描述

multiplier

double

设置预取大小的乘数,该乘数将用于定义非持久性主题在消息被丢弃之前允许的最大挂起消息数量。

<proxyConnector> 元素

属性

属性名称

类型

描述

bind

java.net.URI

localUri

java.net.URI

name

java.lang.String

remote

java.net.URI

server

org.apache.activemq.transport.TransportServer

<queryBasedSubscriptionRecoveryPolicy> 元素

此 {@link SubscriptionRecoveryPolicy} 的实现将执行用户特定的查询机制以加载他们可能错过的任何消息。

属性

属性名称

类型

描述

query

org.apache.activemq.broker.region.policy.MessageQuery

设置查询策略以加载初始消息

<queue> 元素

一个 ActiveMQ Classic 队列目标

属性

属性名称

类型

描述

compositeDestinations

(org.apache.activemq.command.ActiveMQDestination)*

name

java.lang.String

physicalName

java.lang.String

properties

java.util.Properties

获取此实例的属性以存储在 JNDI 中

<quickJournalPersistenceAdapter> 元素

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

属性

属性名称

类型

描述

journal

org.apache.activeio.journal.Journal

longTermPersistence

org.apache.activemq.store.PersistenceAdapter

maxCheckpointMessageAddSize

int

maxCheckpointWorkers

int

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

usageManager

org.apache.activemq.memory.UsageManager

useExternalMessageReferences

boolean

<rapidPersistenceAdapter> 元素

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

属性

属性名称

类型

描述

journal

org.apache.activeio.journal.Journal

maxCheckpointMessageAddSize

int

maxCheckpointWorkers

int

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

usageManager

org.apache.activemq.memory.UsageManager

useExternalMessageReferences

boolean

<roundRobinDispatchPolicy> 元素

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<sharedDeadLetterStrategy> 元素

一个 {@link DeadLetterStrategy} 的默认实现,它使用一个常量目标。

属性

属性名称

类型

描述

deadLetterQueue

org.apache.activemq.command.ActiveMQDestination

<simpleAuthenticationPlugin> 元素

提供一个简单的身份验证插件,使用用户密码映射和用户组映射进行配置

属性

属性名称

类型

描述

userGroups

java.util.Map

设置用户所属的组。键是用户名,值是组的集合

userPasswords

java.util.Map

设置以用户名为索引的映射,其值为密码

<simpleAuthorizationMap> 元素

一个 AuthorizationMap,它使用每个操作的单个 DestinationMaps 进行配置。

属性

属性名称

类型

描述

adminACLs

org.apache.activemq.filter.DestinationMap

readACLs

org.apache.activemq.filter.DestinationMap

writeACLs

org.apache.activemq.filter.DestinationMap

<simpleDispatchPolicy> 元素

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<simpleJmsMessageConvertor> 元素

将消息从一个 JMS 转换为另一个 JMS

属性

属性名称

类型

描述

connection

javax.jms.Connection

<statements> 元素

属性

属性名称

类型

描述

addMessageStatement

java.lang.String

binaryDataType

java.lang.String

containerNameDataType

java.lang.String

createDurableSubStatement

java.lang.String

createSchemaStatements

(java.lang.String)*

deleteOldMessagesStatement

java.lang.String

deleteSubscriptionStatement

java.lang.String

dropSchemaStatements

(java.lang.String)*

durableSubAcksTableName

java.lang.String

findAllDestinationsStatement

java.lang.String

findAllDurableSubMessagesStatement

java.lang.String

findAllDurableSubsStatement

java.lang.String

findAllMessagesStatement

java.lang.String

findDurableSubStatement

java.lang.String

findLastSequenceIdInAcksStatement

java.lang.String

findLastSequenceIdInMsgsStatement

java.lang.String

findMessageSequenceIdStatement

java.lang.String

findMessageStatement

java.lang.String

lockCreateStatement

java.lang.String

lockTableName

java.lang.String

lockUpdateStatement

java.lang.String

longDataType

java.lang.String

messageTableName

java.lang.String

msgIdDataType

java.lang.String

removeAllMessagesStatement

java.lang.String

removeAllSubscriptionsStatement

java.lang.String

removeMessageStatment

java.lang.String

sequenceDataType

java.lang.String

stringIdDataType

java.lang.String

tablePrefix

java.lang.String

updateLastAckOfDurableSubStatement

java.lang.String

updateMessageStatement

java.lang.String

useExternalMessageReferences

boolean

useLockCreateWhereClause

boolean

<streamJDBCAdapter> 元素

该 JDBCAdapter 使用 setBinaryStream()/getBinaryStream() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

  • Axion

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<strictOrderDispatchPolicy> 元素

分派策略,使每个订阅按相同顺序看到消息。

<timedSubscriptionRecoveryPolicy> 元素

此 {@link SubscriptionRecoveryPolicy} 的实现将在内存中保留一个定时消息缓冲区,并使用它来恢复新的订阅。

属性

属性名称

类型

描述

recoverDuration

long

<topic> 元素

一个 ActiveMQ Classic 主题目标

属性

属性名称

类型

描述

compositeDestinations

(org.apache.activemq.command.ActiveMQDestination)*

name

java.lang.String

physicalName

java.lang.String

properties

java.util.Properties

获取此实例的属性以存储在 JNDI 中

<transportConnector> 元素

属性

属性名称

类型

描述

broker

org.apache.activemq.broker.Broker

brokerInfo

org.apache.activemq.command.BrokerInfo

brokerName

java.lang.String

connectUri

java.net.URI

disableAsyncDispatch

boolean

discoveryAgent

org.apache.activemq.transport.discovery.DiscoveryAgent

discoveryUri

java.net.URI

messageAuthorizationPolicy

org.apache.activemq.security.MessageAuthorizationPolicy

设置用于决定当前连接是否有权消费给定消息的策略

name

java.lang.String

server

org.apache.activemq.transport.TransportServer

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

uri

java.net.URI

如果通过 {@link #setServer(TransportServer)} 方法未配置 {@link TransportServer},则设置要使用的服务器传输 URI。此值用于延迟创建 {@link TransportServer} 实例

<usageManager> 元素

用于跟踪某个东西的使用量,以便可以控制生产性工作集使用量。主要用例是管理内存使用量。

属性

属性名称

类型

描述

limit

long

设置以字节为单位的内存限制

limitKb

long

设置以千字节为单位的内存限制

limitMb

long

设置以兆字节为单位的内存限制

parent

org.apache.activemq.memory.UsageManager

percentUsage

int

percentUsageMinDelta

int

设置使用率必须变化的最小百分比点数,然后管理器才会触发 UsageListener 事件。

<virtualDestinationInterceptor> 元素

实现 虚拟主题

属性

属性名称

类型

描述

virtualDestinations

(org.apache.activemq.broker.region.virtual.VirtualDestination)*

<virtualTopic> 元素

使用前缀和后缀创建 虚拟主题。虚拟目标创建一个通配符,然后使用该通配符查找所有匹配的活动队列订阅。

属性

属性名称

类型

描述

name

java.lang.String

postfix

java.lang.String

设置用于标识队列消费者的任何后缀

prefix

java.lang.String

设置用于标识给定主题的队列消费者的前缀通配符

元素索引

<authorizationEntry>

表示 {@link DefaultAuthorizationMap} 中的一个条目,用于将用户角色的不同操作(读取、写入、管理)分配给特定目标或目标的层次通配符区域。

<authorizationMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。映射中的每个条目都代表每个操作的授权 ACL。

<authorizationPlugin>

一个授权插件,在对目标执行每个操作时,都会根据授权映射进行检查

<axionJDBCAdapter>

Axion 特定适配器。Axion 似乎不支持 ALTER 语句或子选择。这意味着:- 我们无法自动升级我们在推出 ActiveMQ Classic 的新版本时使用的架构 - 我们无法删除已被所有消费者确认的持久订阅消息。

<blobJDBCAdapter>

该 JDBCAdapter 使用 getBlob()/setBlob() 操作插入和提取 BLOB 数据。这有点复杂,因为要插入一个 blob,您需要执行以下操作:1:插入空 blob。2:选择 blob。3:最后使用数据值更新 blob。使用该适配器的数据库/JDBC 驱动程序为

<broker>

一个 ActiveMQ Classic 消息代理,它包含多个传输连接器、网络连接器和持久化适配器

<bytesJDBCAdapter>

该 JDBCAdapter 使用 setBytes()/getBytes() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

<compositeDemandForwardingBridge>

一个按需转发桥接器,它与多播式传输一起工作,其中单个传输可以与多个远程代理进行通信

<compositeQueue>

表示一个虚拟队列,它转发到多个其他目标。

<compositeTopic>

表示一个虚拟主题,它转发到多个其他目标。

<connectionDotFilePlugin>

一个创建 DOT 文件的插件,该插件会创建一个显示当前连接的 DOT 文件

<constantPendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 被配置为对所有订阅使用常量值。

<db2JDBCAdapter>

<defaultJDBCAdapter>

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

<demandForwardingBridge>

根据需要将消息从本地代理转发到远程代理。

<destinationDotFilePlugin>

一个创建 DOT 文件的插件,该插件会创建一个显示当前主题和队列层次结构的 DOT 文件。

<destinationEntry>

DestinationMap 中的默认条目,它包含单个值。

<fixedCountSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

<fixedSizedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将在 RAM 中保留固定数量的内存以用于消息历史记录,这些消息历史记录将按时间顺序逐出。

<forwardingBridge>

将来自本地代理的所有消息转发到远程代理。

<imageBasedJDBCAdaptor>

提供 JDBCAdapter,因为它使用 IMAGE 数据类型来保存二进制数据。使用该适配器的数据库/JDBC 驱动程序为

  • Sybase
  • MS SQL

<inboundQueueBridge>

创建一个入站队列桥接器

<inboundTopicBridge>

创建一个入站主题桥接器

<individualDeadLetterStrategy>

一个 {@link DeadLetterStrategy},其中每个目标都有使用主题命名层次结构的自己的独立 DLQ。

<informixJDBCAdapter>

用于 Informix 数据库的 JDBC 适配器。由于 Informix 数据库限制复合主键的长度,因此容器名称字段和订阅 ID字段的长度必须缩短至 150 个字符。因此,请确保容器名称和订阅 ID 的名称长度不超过 150 个字符。

<jaasAuthenticationPlugin>

提供基于 JAAS 的身份验证插件

<jdbcPersistenceAdapter>

一个使用 JDBC 进行持久化存储的 {@link PersistenceAdapter} 实现。该持久化适配器将正确记住准备好的 XA 事务,但它不会跟踪本地事务提交,以便对消息存储执行的操作作为单个 uow 执行。

<jmsQueueConnector>

与其他 JMS 队列提供程序的桥接器

<jmsTopicConnector>

与其他 JMS 主题提供程序的桥接器

<journalPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

<journaledJDBC>

使用日志和 JDBC 创建默认持久化模型

<kahaPersistenceAdapter>

<lastImageSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将只保留最后一条消息。

<loggingBrokerPlugin>

一个简单的代理拦截器,允许您启用/禁用日志记录。

<managementContext>

Flow 在 NMR 中提供不同的分派策略

<memoryPersistenceAdapter>

<multicastNetworkConnector>

一个网络连接器,它使用某种多播式传输来与单个逻辑 {@link Transport} 实例上的多个潜在远程代理进行通信,例如在使用多播时。此实现完全不依赖于多播;任何其他基于组的传输都可以使用。

<networkConnector>

一个网络连接器,它使用发现代理来检测可用的远程代理并建立到每个可用远程代理的连接

<noSubscriptionRecoveryPolicy>

这是默认主题恢复策略,它不会恢复任何消息。

<oldestMessageEvictionStrategy>

一种逐出策略,它首先逐出最旧的消息(这是默认设置)。

<oldestMessageWithLowestPriorityEvictionStrategy>

一种逐出策略,它首先逐出优先级最低的最旧的消息。

<oracleJDBCAdapter>

实现 JDBCPersistenceAdapter 使用的所有默认 JDBC 操作。

鼓励子类化以覆盖方法的默认实现,以解决 JDBC 驱动程序实现之间的差异。

JDBCAdapter 使用 getBytes()/setBytes() 操作插入和提取 BLOB 数据。

使用该适配器的数据库/JDBC 驱动程序为

<outboundQueueBridge>

创建一个出站队列桥接器

<outboundTopicBridge>

创建一个出站主题桥接器

<policyEntry>

表示 {@link PolicyMap} 中的一个条目,用于将策略分配给特定目标或目标的层次通配符区域。

<policyMap>

表示基于目标的策略配置,因此可以使用不同的策略配置单个目标或目标的通配符层次结构。

<prefetchRatePendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 将最大待处理消息限制值设置为订阅预取限制的倍数。

<proxyConnector>

<queryBasedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将执行用户特定的查询机制以加载他们可能错过的任何消息。

<queue>

一个 ActiveMQ Classic 队列目标

<quickJournalPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

<rapidPersistenceAdapter>

一个 {@link PersistenceAdapter} 的实现,旨在与 {@link Journal} 一起使用,然后在超时时与其他长期持久存储进行异步检查点。

<roundRobinDispatchPolicy>

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<sharedDeadLetterStrategy>

一个 {@link DeadLetterStrategy} 的默认实现,它使用一个常量目标。

<simpleAuthenticationPlugin>

提供一个简单的身份验证插件,使用用户密码映射和用户组映射进行配置

<simpleAuthorizationMap>

一个 AuthorizationMap,它使用每个操作的单个 DestinationMaps 进行配置。

<simpleDispatchPolicy>

简单的分派策略,将消息发送到与该消息匹配的每个订阅。

<simpleJmsMessageConvertor>

将消息从一个 JMS 转换为另一个 JMS

<statements>

<streamJDBCAdapter>

该 JDBCAdapter 使用 setBinaryStream()/getBinaryStream() 操作插入和提取 BLOB 数据。使用该适配器的数据库/JDBC 驱动程序为

  • Axion

<strictOrderDispatchPolicy>

分派策略,使每个订阅按相同顺序看到消息。

<timedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将在内存中保留一个定时消息缓冲区,并使用它来恢复新的订阅。

<topic>

一个 ActiveMQ Classic 主题目标

<transportConnector>

<usageManager>

用于跟踪某个东西的使用量,以便可以控制生产性工作集使用量。主要用例是管理内存使用量。

<virtualDestinationInterceptor>

实现 虚拟主题.

<virtualTopic>

使用前缀和后缀创建 虚拟主题。虚拟目标创建一个通配符,然后使用该通配符查找所有匹配的活动队列订阅。

Apache、ActiveMQ、Apache ActiveMQ、Apache 羽毛标志和 Apache ActiveMQ 项目标志是 Apache 软件基金会的商标。版权所有 © 2024,Apache 软件基金会。根据 Apache 许可证 2.0 授权。