XBean XML 参考 5.0

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

元素类型

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

<transportConnector>

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

<inboundQueueBridge>

创建入站队列桥

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

<ldapNetworkConnector>

类用于创建使用 LDAP v3 协议(如 RFC 2251 中定义)在目录服务器中列出的动态网络连接器,目录服务器中列出的条目必须实现 RFC 2307 中定义的 ipHost 和 ipService 对象类。

<multicastNetworkConnector>

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

<networkConnector>

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

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

<broker>

一个 ActiveMQ Classic 消息代理。它包含多个传输连接器、网络连接器以及一堆属性,这些属性可用于配置代理,因为它是在延迟创建时创建的。

org.apache.activemq.usage.TempUsage 类型实现

<tempUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

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

<fileCursor>

挂起的邮件

<vmCursor>

挂起的邮件保留

org.apache.activemq.usage.MemoryUsage 类型实现

<memoryUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

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

<authorizationPlugin>

一个授权插件,其中对目的地的每个操作都会针对授权映射进行检查

<connectionDotFilePlugin>

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

<destinationDotFilePlugin>

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

<jaasAuthenticationPlugin>

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

<jaasCertificateAuthenticationPlugin>

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

<loggingBrokerPlugin>

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

<multicastTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到多播套接字。

<simpleAuthenticationPlugin>

提供一个简单的身份验证插件

<timeStampingBrokerPlugin>

一个代理拦截器,使用代理时间戳更新 JMS 客户端的邮件时间戳。当客户端机器上的时钟已知不正确,并且您只能信任代理机器上设置的时间时,这很有用。启用此插件将破坏 JMS 兼容性,因为生产者在发送后看到的邮件上的时间戳将不同于消费者接收邮件时观察到的时间戳。此插件在默认 ActiveMQ Classic 配置中未启用。

<udpTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到 UDP 套接字。

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

<axionJDBCAdapter>

Axion 专用适配器。Axion 似乎不支持 ALTER 语句或子查询。这意味着: - 我们无法在推出 ActiveMQ Classic 的新版本时自动升级模式 - 我们无法删除已由所有消费者确认的持久订阅邮件。

<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

<informixJDBCAdapter>

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

<oracleJDBCAdapter>

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

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

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

使用此适配器的数据库/JDBC 驱动程序是

<streamJDBCAdapter>

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

  • Axion

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

<fileQueueCursor>

挂起

<storeCursor>

挂起的邮件

<vmQueueCursor>

挂起的邮件

javax.jms.TopicConnectionFactory 类型实现

<connectionFactory>

一个经过 Spring 增强的连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

<xaConnectionFactory>

一个经过 Spring 增强的 XA 连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

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

<compositeQueue>

表示将转发到多个其他目的地的虚拟队列。

<compositeTopic>

表示将转发到多个其他目的地的虚拟主题。

<virtualTopic>

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

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

<policyMap>

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

org.apache.activemq.usage.UsageCapacity 类型实现

<defaultUsageCapacity>

识别是否已达到限制

<usageCapacity>

识别是否已达到限制

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

<constantPendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 被配置为对所有订阅的常数值。

<prefetchRatePendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 将最大挂起邮件限制值设置为订阅预取限制的倍数。

org.apache.activemq.usage.SystemUsage 类型实现

<systemUsage>

内存、存储和临时文件的 Usage 实例的持有者 主要用例是管理内存使用情况。

javax.jms.Destination 类型实现

<queue>

一个 ActiveMQ Classic 队列

<topic>

一个 ActiveMQ Classic 主题

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

<fixedCountSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将保留固定数量的最后邮件。

<fixedSizedSubscriptionRecoveryPolicy>

此 {@link SubscriptionRecoveryPolicy} 的实现将保留固定数量的内存,供 RAM 中的邮件历史记录使用,该内存历史记录会按时间顺序逐出。

<lastImageSubscriptionRecoveryPolicy>

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

<noSubscriptionRecoveryPolicy>

此 SubscriptionRecoveryPolicy 禁用邮件恢复。

<queryBasedSubscriptionRecoveryPolicy>

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

<timedSubscriptionRecoveryPolicy>

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

javax.jms.QueueConnectionFactory 类型实现

<connectionFactory>

一个经过 Spring 增强的连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

<xaConnectionFactory>

一个经过 Spring 增强的 XA 连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

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

<managementContext>

流在 NMR 中提供不同的调度策略

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

<statements>

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

<amqPersistenceAdapterFactory>

{@link PersistenceAdapterFactory} 的一个实现

<journaledJDBC>

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

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

<authorizationEntry>

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

<tempDestinationAuthorizationEntry>

表示 {@link DefaultAuthorizationMap} 中的条目,用于将用户角色的不同操作(读取、写入、管理)分配给临时目的地

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

<fileDurableSubscriberCursor>

持久订阅者的挂起邮件

<storeDurableSubscriberCursor>

持久订阅者的挂起邮件

<vmDurableCursor>

挂起

org.apache.activemq.broker.region.group.MessageGroupMapFactory 类型实现

<messageGroupHashBucketFactory>

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

<simpleMessageGroupMapFactory>

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

org.apache.activemq.usage.StoreUsage 类型实现

<storeUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

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

<individualDeadLetterStrategy>

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

<sharedDeadLetterStrategy>

一个 {@link DeadLetterStrategy} 的默认实现,它使用恒定目的地。

javax.jms.Topic 类型实现

<topic>

一个 ActiveMQ Classic 主题

org.apache.activemq.ActiveMQPrefetchPolicy 类型实现

<prefetchPolicy>

定义不同类型消费者的预取邮件策略

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

<loggingBrokerPlugin>

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

<multicastTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到多播套接字。

<timeStampingBrokerPlugin>

一个代理拦截器,使用代理时间戳更新 JMS 客户端的邮件时间戳。当客户端机器上的时钟已知不正确,并且您只能信任代理机器上设置的时间时,这很有用。启用此插件将破坏 JMS 兼容性,因为生产者在发送后看到的邮件上的时间戳将不同于消费者接收邮件时观察到的时间戳。此插件在默认 ActiveMQ Classic 配置中未启用。

<udpTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到 UDP 套接字。

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

<amqPersistenceAdapter>

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

<jdbcPersistenceAdapter>

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

<journalPersistenceAdapter>

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

<kahaPersistenceAdapter>

<memoryPersistenceAdapter>

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.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.RedeliveryPolicy 类型实现

<redeliveryPolicy>

用于控制消息回滚时如何重新传递消息的配置选项。

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

<authorizationMap>

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

<lDAPAuthorizationMap>

一个使用 LDAP 的 {@link AuthorizationMap}

<simpleAuthorizationMap>

一个使用每个操作的单个 DestinationMap 配置的 AuthorizationMap。

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

<tempDestinationAuthorizationEntry>

表示 {@link DefaultAuthorizationMap} 中的条目,用于将用户角色的不同操作(读取、写入、管理)分配给临时目的地

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

<roundRobinDispatchPolicy>

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

<simpleDispatchPolicy>

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

<strictOrderDispatchPolicy>

调度策略,使每个订阅以相同的顺序查看消息。

javax.jms.ConnectionFactory 类型实现

<connectionFactory>

一个经过 Spring 增强的连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

<xaConnectionFactory>

一个经过 Spring 增强的 XA 连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

javax.jms.Queue 类型实现

<queue>

一个 ActiveMQ Classic 队列

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

<oldestMessageEvictionStrategy>

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

<oldestMessageWithLowestPriorityEvictionStrategy>

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

org.apache.activemq.Service 类型实现

<broker>

一个 ActiveMQ Classic 消息代理。它包含多个传输连接器、网络连接器以及一堆属性,这些属性可用于配置代理,因为它是在延迟创建时创建的。

<commandAgent>

一个在 JMS 目的地上监听命令的代理

<forwardingBridge>

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

<inboundQueueBridge>

创建入站队列桥

<inboundTopicBridge>

创建一个入站主题桥

<jmsQueueConnector>

一个连接到其他 JMS 队列提供程序的桥

<jmsTopicConnector>

一个连接到其他 JMS 主题提供程序的桥

<ldapNetworkConnector>

类用于创建使用 LDAP v3 协议(如 RFC 2251 中定义)在目录服务器中列出的动态网络连接器,目录服务器中列出的条目必须实现 RFC 2307 中定义的 ipHost 和 ipService 对象类。

<managementContext>

流在 NMR 中提供不同的调度策略

<masterConnector>

使用 主从 来实现消息的高可用性时,将从属代理连接到主代理。

<memoryUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

<multicastNetworkConnector>

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

<networkConnector>

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

<outboundQueueBridge>

创建一个出站队列桥

<outboundTopicBridge>

创建一个出站主题桥

<proxyConnector>

<storeUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

<systemUsage>

内存、存储和临时文件的 Usage 实例的持有者 主要用例是管理内存使用情况。

<tempUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

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

<simpleJmsMessageConvertor>

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

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

<outboundTopicBridge>

创建一个出站主题桥

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

<mirroredQueue>

使用前缀和后缀创建 镜像队列,以定义要镜像队列的主题名称。

<virtualDestinationInterceptor>

实现 虚拟主题

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

<authorizationMap>

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

<policyMap>

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

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

<ldapNetworkConnector>

类用于创建使用 LDAP v3 协议(如 RFC 2251 中定义)在目录服务器中列出的动态网络连接器,目录服务器中列出的条目必须实现 RFC 2307 中定义的 ipHost 和 ipService 对象类。

<multicastNetworkConnector>

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

<networkConnector>

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

<amqPersistenceAdapter> 元素

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

属性

属性名称

类型

描述

archiveDataLogs

boolean

asyncDataManager

org.apache.activemq.kaha.impl.async.AsyncDataManager

brokerName

java.lang.String

brokerService

org.apache.activemq.broker.BrokerService

checkpointInterval

long

cleanupInterval

long

directory

java.io.File

directoryArchive

java.io.File

indexBinSize

int

indexKeySize

int

indexPageSize

int

使用 XBean 设置时,可以使用诸如“20 mb”、“1024 kb”或“1 gb”之类的值

maxCheckpointMessageAddSize

int

使用 XBean 设置时,可以使用诸如“20 mb”、“1024 kb”或“1 gb”之类的值

maxFileLength

int

使用 XBean 设置时,可以使用诸如“20 mb”、“1024 kb”或“1 gb”之类的值

persistentIndex

boolean

referenceStoreAdapter

org.apache.activemq.store.ReferenceStoreAdapter

syncOnWrite

boolean

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

usageManager

org.apache.activemq.usage.SystemUsage

useNio

boolean

wireFormat

org.apache.activemq.wireformat.WireFormat

<amqPersistenceAdapterFactory> 元素

{@link PersistenceAdapterFactory} 的一个实现

属性

属性名称

类型

描述

brokerName

java.lang.String

dataDirectory

java.io.File

journalThreadPriority

int

maxFileLength

int

persistentIndex

boolean

referenceStoreAdapter

org.apache.activemq.store.ReferenceStoreAdapter

syncOnWrite

boolean

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

useNio

boolean

<authenticationUser> 元素

用于配置简单身份验证插件的辅助对象

属性

属性名称

类型

描述

groups

java.lang.String

password

java.lang.String

username

java.lang.String

<authorizationEntry> 元素

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

属性

属性名称

类型

描述

admin

java.lang.String

adminACLs

(java.lang.Object)*

destination

org.apache.activemq.command.ActiveMQDestination

groupClass

java.lang.String

queue

java.lang.String

从配置文件设置目的地的辅助方法

read

java.lang.String

readACLs

(java.lang.Object)*

topic

java.lang.String

从配置文件设置目的地的辅助方法

write

java.lang.String

writeACLs

(java.lang.Object)*

<authorizationMap> 元素

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

属性

属性名称

类型

描述

authorizationEntries

(java.lang.Object)*

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

defaultEntry

org.apache.activemq.security.AuthorizationEntry

entries

(java.lang.Object)*

一个辅助方法,允许从依赖注入框架(如 Spring)填充目的地映射

tempDestinationAuthorizationEntry

org.apache.activemq.security.TempDestinationAuthorizationEntry

<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

clustered

boolean

consumerSystemUsage

org.apache.activemq.usage.SystemUsage

dataDirectory

java.lang.String

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

dataDirectoryFile

java.io.File

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

deleteAllMessagesOnStartup

boolean

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

destinationFactory

org.apache.activemq.broker.region.DestinationFactory

destinationInterceptors

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

设置要使用的目的地拦截器

destinationPolicy

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

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

destinations

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

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

enableStatistics

boolean

设置代理的服务是否启用统计信息。

jmsBridgeConnectors

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

keepDurableSubsActive

boolean

managementContext

org.apache.activemq.broker.jmx.ManagementContext

masterConnectorURI

java.lang.String

messageAuthorizationPolicy

org.apache.activemq.security.MessageAuthorizationPolicy

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

networkConnectorURIs

(java.lang.String)*

networkConnectors

(org.apache.activemq.network.NetworkConnector)*

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

persistenceAdapter

org.apache.activemq.store.PersistenceAdapter

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

persistenceFactory

org.apache.activemq.store.PersistenceAdapterFactory

persistenceTaskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

persistenceThreadPriority

int

persistent

boolean

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

plugins

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

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

populateJMSXUserID

boolean

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

producerSystemUsage

org.apache.activemq.usage.SystemUsage

proxyConnectors

(java.lang.Object)*

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

services

(org.apache.activemq.Service)*

设置与此代理关联的服务,例如 {@link MasterConnector}

shutdownOnMasterFailure

boolean

start

boolean

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

supportFailOver

boolean

systemUsage

org.apache.activemq.usage.SystemUsage

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

tempDataStore

org.apache.activemq.kaha.Store

tmpDataDirectory

java.io.File

transportConnectorURIs

(java.lang.String)*

transportConnectors

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

设置此代理将用于监听新客户端的传输连接器

useJmx

boolean

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

useLocalHostBrokerName

boolean

useLoggingForShutdownErrors

boolean

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

useMirroredQueues

boolean

设置如果未明确配置,默认情况下是否应支持 镜像队列

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

<commandAgent> 元素

一个在 JMS 目的地上监听命令的代理

属性

属性名称

类型

描述

brokerUrl

java.lang.String

commandDestination

javax.jms.Destination

connection

javax.jms.Connection

connectionFactory

javax.jms.ConnectionFactory

<compositeDemandForwardingBridge> 元素

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

属性

属性名称

类型

描述

configuration

org.apache.activemq.network.NetworkBridgeConfiguration

createdByDuplex

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

networkBridgeListener

org.apache.activemq.network.NetworkBridgeListener

remoteBroker

org.apache.activemq.transport.Transport

staticallyIncludedDestinations

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

<compositeQueue> 元素

表示将转发到多个其他目的地的虚拟队列。

属性

属性名称

类型

描述

copyMessage

boolean

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

forwardOnly

boolean

设置虚拟目的地是仅转发(因此没有物理队列与虚拟队列匹配)还是还存在具有相同名称的物理队列。

forwardTo

(java.lang.Object)*

设置要转发到的目的地列表

name

java.lang.String

设置此组合目的地的名称

<compositeTopic> 元素

表示将转发到多个其他目的地的虚拟主题。

属性

属性名称

类型

描述

copyMessage

boolean

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

forwardOnly

boolean

设置虚拟目的地是仅转发(因此没有物理队列与虚拟队列匹配)还是还存在具有相同名称的物理队列。

forwardTo

(java.lang.Object)*

设置要转发到的目的地列表

name

java.lang.String

设置此组合目的地的名称

<connectionDotFilePlugin> 元素

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

属性

属性名称

类型

描述

文件

java.lang.String

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

<connectionFactory> 元素

一个经过 Spring 增强的连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

属性

属性名称

类型

描述

alwaysSessionAsync

boolean

如果设置了此标志,则不会为连接中的每个会话使用单独的线程来调度消息。但是,如果有多个会话,或者会话不在自动确认或重复确认模式下,则始终使用单独的线程

alwaysSyncSend

boolean

如果始终需要消息进行同步发送,则设置为 true

beanName

java.lang.String

blobTransferPolicy

org.apache.activemq.blob.BlobTransferPolicy

设置用于描述如何将带外 BLOB(二进制大对象)从生产者传输到代理再到消费者的策略

brokerURL

java.lang.String

设置用于连接到 ActiveMQ Classic 代理的 连接 URL

clientID

java.lang.String

设置要为创建的连接使用的 JMS clientID。请注意,这只能被一个连接使用一次,因此通常最好在连接上设置 clientID

clientIDPrefix

java.lang.String

设置自动生成的 JMS 客户端 ID 值使用的前缀,这些值在 JMS 客户端未明确指定的情况下使用。

clientIdGenerator

org.apache.activemq.util.IdGenerator

closeTimeout

int

设置关闭操作完成之前的时间超时。通常,连接上的 close() 方法等待来自代理的确认;这允许该操作超时,以防止客户端在没有代理的情况下挂起

copyMessageOnSend

boolean

JMS 消息是否应作为 JMS 中 send() 方法的一部分被复制到新的 JMS 消息对象。默认情况下启用此功能,以符合 JMS 规范。如果在发送 JMS 消息后不修改它们,则可以禁用它以提高性能

disableTimeStampsByDefault

boolean

设置消息上的时间戳是否应禁用。如果禁用它们,则会略微提高性能。

dispatchAsync

boolean

启用或禁用消费者是否由代理 同步或异步调度 消息的默认设置。例如,对于非持久主题,我们通常默认情况下同步调度,以最大程度地减少上下文切换,从而提高性能。但是,有时最好放慢速度,以确保单个阻塞的消费者套接字不会阻止消息传递到其他消费者。

exclusiveConsumer

boolean

启用或禁用队列消费者是否应该是排他的,例如,在不使用 消息组 的情况下保留排序

nestedMapAndListEnabled

boolean

启用/禁用消息属性和 MapMessage 条目是否支持 Map 和 List 对象的嵌套结构

objectMessageSerializationDefered

boolean

当在 ObjectMessage 上设置对象时,JMS 规范要求该对象通过该 set 方法序列化。启用此标志会导致对象不进行序列化。如果需要通过套接字发送消息或将其存储到磁盘,则该对象可能会随后进行序列化。

optimizeAcknowledge

boolean

optimizedMessageDispatch

boolean

如果设置了此标志,则使用更大的预取限制 - 仅适用于持久主题订阅者。

password

java.lang.String

设置从该工厂创建的连接使用的 JMS 密码

prefetchPolicy

org.apache.activemq.ActiveMQPrefetchPolicy

设置由该连接创建的消费者的 预取策略

producerWindowSize

int

properties

java.util.Properties

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

redeliveryPolicy

org.apache.activemq.RedeliveryPolicy

设置在消息传递但会话回滚时要使用的全局重新传递策略

statsEnabled

boolean

transformer

org.apache.activemq.MessageTransformer

设置在将消息发送到 JMS 总线之前或从总线接收它们但将其传递到 JMS 客户端之前对其进行转换的转换器

transportListener

org.apache.activemq.transport.TransportListener

允许在 ConnectionFactory 上配置一个监听器,以便当此工厂与不公开连接的框架(例如 Spring JmsTemplate)一起使用时,您仍然可以注册传输监听器。

useAsyncSend

boolean

强制使用 异步发送,这会大幅提高性能;但这意味着 send() 方法将立即返回,无论消息是否已发送,这可能会导致消息丢失。

useBeanNameAsClientIdPrefix

boolean

useCompression

boolean

启用消息体的压缩使用

useRetroactiveConsumer

boolean

设置是否启用追溯消费者。追溯消费者允许非持久主题订阅者接收在非持久订阅者启动之前发布的旧消息。

userName

java.lang.String

设置由该工厂创建的连接使用的 JMS 用户名

warnAboutUnstartedConnectionTimeout

long

启用从连接创建到生成警告之间的超时,如果连接未通过 {@link Connection#start()} 正确启动并且消费者接收到消息。忘记 启动连接 是一个非常常见的错误,因此此选项使默认情况下会在用户忘记的情况下创建警告。要禁用警告,只需将值设置为 < 0(例如 -1)。

watchTopicAdvisories

boolean

<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

<defaultUsageCapacity> 元素

识别是否已达到限制

属性

属性名称

类型

描述

limit

long

<demandForwardingBridge> 元素

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

属性

属性名称

类型

描述

configuration

org.apache.activemq.network.NetworkBridgeConfiguration

createdByDuplex

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

networkBridgeListener

org.apache.activemq.network.NetworkBridgeListener

remoteBroker

org.apache.activemq.transport.Transport

staticallyIncludedDestinations

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

<destinationDotFilePlugin> 元素

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

属性

属性名称

类型

描述

文件

java.lang.String

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

<destinationEntry> 元素

DestinationMap 中的默认条目,它保存单个值。

属性

属性名称

类型

描述

destination

org.apache.activemq.command.ActiveMQDestination

queue

java.lang.String

从配置文件设置目的地的辅助方法

topic

java.lang.String

从配置文件设置目的地的辅助方法

value

java.lang.Object

<fileCursor> 元素

挂起的邮件

<fileDurableSubscriberCursor> 元素

持久订阅者的挂起邮件

<fileQueueCursor> 元素

挂起

<filteredDestination> 元素

表示使用某些谓词(例如选择器)进行过滤的目标,以便只有与过滤器匹配的消息才会被调度到目标。

属性

属性名称

类型

描述

destination

org.apache.activemq.command.ActiveMQDestination

如果消息与过滤器匹配,则发送消息的目标

filter

org.apache.activemq.filter.BooleanExpression

queue

java.lang.String

将目标属性设置为给定的队列名称

selector

java.lang.String

设置在将消息转发到此目标之前用于过滤消息的 JMS 选择器

topic

java.lang.String

将目标属性设置为给定的主题名称

<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

networkBridgeFailedListener

org.apache.activemq.network.NetworkBridgeListener

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

localQueueName

java.lang.String

maximumRetries

int

设置在发送失败后尝试关闭桥接之前的最大重试次数

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

localTopicName

java.lang.String

maximumRetries

int

设置在发送失败后尝试关闭桥接之前的最大重试次数

producerConnection

javax.jms.TopicConnection

producerTopic

javax.jms.Topic

selector

java.lang.String

<individualDeadLetterStrategy> 元素

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

属性

属性名称

类型

描述

processExpired

boolean

processNonPersistent

boolean

queuePrefix

java.lang.String

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

topicPrefix

java.lang.String

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

useQueueForQueueMessages

boolean

设置应为发送到 DLQ 的队列消息使用队列还是主题。默认情况下使用队列

useQueueForTopicMessages

boolean

设置应为发送到 DLQ 的主题消息使用队列还是主题。默认情况下使用队列

<informixJDBCAdapter> 元素

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

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<jaasAuthenticationPlugin> 元素

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

属性

属性名称

类型

描述

configuration

java.lang.String

设置使用的 JAAS 配置域名称

discoverLoginConfig

boolean

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

<jaasCertificateAuthenticationPlugin> 元素

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

属性

属性名称

类型

描述

configuration

java.lang.String

设置使用的 JAAS 配置域名称

discoverLoginConfig

boolean

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

<jdbcPersistenceAdapter> 元素

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

属性

属性名称

类型

描述

adapter

org.apache.activemq.store.jdbc.JDBCAdapter

brokerName

java.lang.String

brokerService

org.apache.activemq.broker.BrokerService

cleanupPeriod

int

设置尝试清理数据库以用于持久主题的时间间隔(以毫秒为单位)

createTablesOnStartup

boolean

设置启动时是否创建表

dataDirectory

java.lang.String

dataDirectoryFile

java.io.File

dataSource

javax.sql.DataSource

databaseLocker

org.apache.activemq.store.jdbc.DatabaseLocker

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

directory

java.io.File

ds

javax.sql.DataSource

scheduledThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

statements

org.apache.activemq.store.jdbc.Statements

usageManager

org.apache.activemq.usage.SystemUsage

useDatabaseLock

boolean

设置是否应使用独占数据库锁以启用 JDBC 主从。默认情况下启用。

useExternalMessageReferences

boolean

wireFormat

org.apache.activemq.wireformat.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} 一起使用,然后在超时时与其他长期持久存储异步检查点。

属性

属性名称

类型

描述

brokerName

java.lang.String

directory

java.io.File

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.usage.SystemUsage

useExternalMessageReferences

boolean

<journaledJDBC> 元素

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

属性

属性名称

类型

描述

adapter

org.apache.activemq.store.jdbc.JDBCAdapter

createTablesOnStartup

boolean

设置启动时是否创建表

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

设置要使用的日志文件数量

journalThreadPriority

int

设置日志线程的线程优先级

statements

org.apache.activemq.store.jdbc.Statements

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

useDatabaseLock

boolean

设置是否应使用独占数据库锁以启用 JDBC 主从。默认情况下启用。

useJournal

boolean

启用或禁用日志的使用。默认情况下使用日志

useQuickJournal

boolean

启用或禁用快速日志的使用,它将消息保留在日志中,并在 JDBC 中仅存储对消息的引用。默认为 false,以便消息实际上长期驻留在 JDBC 数据库中。

<kahaPersistenceAdapter> 元素

属性

属性名称

类型

描述

brokerName

java.lang.String

directory

java.io.File

maxDataFileLength

long

persistentIndex

boolean

size

java.util.concurrent.atomic.AtomicLong

usageManager

org.apache.activemq.usage.SystemUsage

<lDAPAuthorizationMap> 元素

一个使用 LDAP 的 {@link AuthorizationMap}

属性

属性名称

类型

描述

adminAttribute

java.lang.String

adminBase

java.lang.String

authentication

java.lang.String

connectionPassword

java.lang.String

connectionProtocol

java.lang.String

connectionURL

java.lang.String

connectionUsername

java.lang.String

context

javax.naming.directory.DirContext

initialContextFactory

java.lang.String

options

java.util.Map

queueSearchMatchingFormat

java.text.MessageFormat

queueSearchSubtreeBool

boolean

读取属性

java.lang.String

读取基础

java.lang.String

主题搜索匹配格式

java.text.MessageFormat

主题搜索子树布尔值

boolean

写入属性

java.lang.String

写入基础

java.lang.String

<lastImageSubscriptionRecoveryPolicy> 元素

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

<ldapNetworkConnector> 元素

类用于创建使用 LDAP v3 协议(如 RFC 2251 中定义)在目录服务器中列出的动态网络连接器,目录服务器中列出的条目必须实现 RFC 2307 中定义的 ipHost 和 ipService 对象类。

属性

属性名称

类型

描述

基础

java.lang.String

设置用于查找操作的基础 LDAP dn

桥接临时目标

boolean

brokerName

java.lang.String

brokerService

org.apache.activemq.broker.BrokerService

管道订阅

boolean

连接过滤器

org.apache.activemq.network.ConnectionFilter

降低网络消费者优先级

boolean

destinationFilter

java.lang.String

dispatchAsync

boolean

双工

boolean

durableDestinations

(java.lang.Object)*

仅动态

boolean

dynamicallyIncludedDestinations

(java.lang.Object)*

excludedDestinations

(java.lang.Object)*

本地 URI

java.net.URI

name

java.lang.String

网络 TTL

int

对象名称

javax.management.ObjectName

password

java.lang.String

设置用于访问凭据的 LDAP 密码

prefetchSize

int

搜索过滤器

java.lang.String

设置 RFC 2254 中定义的 LDAP 搜索过滤器

搜索范围

java.lang.String

设置 LDAP 搜索范围

staticallyIncludedDestinations

(java.lang.Object)*

URI

java.net.URI

设置 LDAP 服务器 URI

用户

java.lang.String

设置用于访问凭据的 LDAP 用户

userName

java.lang.String

<loggingBrokerPlugin> 元素

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

属性

属性名称

类型

描述

确认日志

org.apache.commons.logging.Log

管理员连接上下文

org.apache.activemq.broker.ConnectionContext

日志

org.apache.commons.logging.Log

下一个

org.apache.activemq.broker.Broker

发送日志

org.apache.commons.logging.Log

<managementContext> 元素

流在 NMR 中提供不同的调度策略

属性

属性名称

类型

描述

MBean 服务器

javax.management.MBeanServer

获取 MBean 服务器

连接器路径

java.lang.String

连接器端口

int

创建连接器

boolean

创建 MBean 服务器

boolean

查找 Tiger Mbean 服务器

boolean

启用/禁用搜索 Java 5 平台 MBean 服务器

JMX 域名称

java.lang.String

RMI 服务器端口

int

服务器

javax.management.MBeanServer

使用 MBean 服务器

boolean

<masterConnector> 元素

使用 主从 来实现消息的高可用性时,将从属代理连接到主代理。

属性

属性名称

类型

描述

brokerService

org.apache.activemq.broker.BrokerService

本地 URI

java.net.URI

password

java.lang.String

远程 URI

java.net.URI

远程 URI

java.lang.String

userName

java.lang.String

<memoryPersistenceAdapter> 元素

属性

属性名称

类型

描述

brokerName

java.lang.String

directory

java.io.File

usageManager

org.apache.activemq.usage.SystemUsage

useExternalMessageReferences

boolean

<memoryUsage> 元素

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

属性

属性名称

类型

描述

limit

long

设置内存限制(以字节为单位)。使用字节设置限制将使用量部分设置为 0,因为 UsageManager 不会基于父项进行部分计算。使用 XBean 设置时,可以使用以下值:“20 mb”、“1024 kb”或“1 gb”

限制器

org.apache.activemq.usage.UsageCapacity

name

java.lang.String

父项

T

使用百分比

int

使用百分比最小增量

int

设置管理器触发 UsageListener 事件之前使用情况必须更改的最小百分比点数。

轮询时间

int

部分

浮点数

使用情况

long

使用量部分

浮点数

<messageGroupHashBucketFactory> 元素

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

属性

属性名称

类型

描述

桶数

int

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

<mirroredQueue> 元素

使用前缀和后缀创建 镜像队列,以定义要镜像队列的主题名称。

属性

属性名称

类型

描述

brokerService

org.apache.activemq.broker.BrokerService

copyMessage

boolean

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

后缀

java.lang.String

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

前缀

java.lang.String

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

<multicastNetworkConnector> 元素

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

属性

属性名称

类型

描述

桥接

org.apache.activemq.network.DemandForwardingBridgeSupport

桥接临时目标

boolean

brokerName

java.lang.String

brokerService

org.apache.activemq.broker.BrokerService

管道订阅

boolean

连接过滤器

org.apache.activemq.network.ConnectionFilter

降低网络消费者优先级

boolean

destinationFilter

java.lang.String

dispatchAsync

boolean

双工

boolean

durableDestinations

(java.lang.Object)*

仅动态

boolean

dynamicallyIncludedDestinations

(java.lang.Object)*

excludedDestinations

(java.lang.Object)*

本地传输

org.apache.activemq.transport.Transport

本地 URI

java.net.URI

name

java.lang.String

网络 TTL

int

对象名称

javax.management.ObjectName

password

java.lang.String

prefetchSize

int

远程传输

org.apache.activemq.transport.Transport

设置远程传输实现

远程 URI

java.net.URI

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

staticallyIncludedDestinations

(java.lang.Object)*

userName

java.lang.String

<multicastTraceBrokerPlugin> 元素

一个代理拦截器,允许您将所有操作跟踪到多播套接字。

属性

属性名称

类型

描述

地址

java.net.SocketAddress

管理员连接上下文

org.apache.activemq.broker.ConnectionContext

广播

boolean

destination

java.net.URI

最大跟踪数据报大小

int

下一个

org.apache.activemq.broker.Broker

生存时间

int

wireFormat

org.apache.activemq.wireformat.WireFormat

线格式工厂

org.apache.activemq.wireformat.WireFormatFactory

<networkConnector> 元素

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

属性

属性名称

类型

描述

桥接临时目标

boolean

brokerName

java.lang.String

brokerService

org.apache.activemq.broker.BrokerService

管道订阅

boolean

连接过滤器

org.apache.activemq.network.ConnectionFilter

降低网络消费者优先级

boolean

destinationFilter

java.lang.String

发现代理

org.apache.activemq.transport.discovery.DiscoveryAgent

发现 URI

java.net.URI

dispatchAsync

boolean

双工

boolean

durableDestinations

(java.lang.Object)*

仅动态

boolean

dynamicallyIncludedDestinations

(java.lang.Object)*

excludedDestinations

(java.lang.Object)*

本地 URI

java.net.URI

name

java.lang.String

网络 TTL

int

对象名称

javax.management.ObjectName

password

java.lang.String

prefetchSize

int

staticallyIncludedDestinations

(java.lang.Object)*

URI

java.net.URI

userName

java.lang.String

<noSubscriptionRecoveryPolicy> 元素

此 SubscriptionRecoveryPolicy 禁用邮件恢复。

<oldestMessageEvictionStrategy> 元素

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

属性

属性名称

类型

描述

驱逐过期消息高水位线

int

设置高水位线,在此水位线我们将积极地从 RAM 中驱逐过期消息

<oldestMessageWithLowestPriorityEvictionStrategy> 元素

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

属性

属性名称

类型

描述

驱逐过期消息高水位线

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

localQueueName

java.lang.String

maximumRetries

int

设置在发送失败后尝试关闭桥接之前的最大重试次数

出站队列名称

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

localTopicName

java.lang.String

maximumRetries

int

设置在发送失败后尝试关闭桥接之前的最大重试次数

出站主题名称

java.lang.String

producerConnection

javax.jms.TopicConnection

producerTopic

javax.jms.Topic

selector

java.lang.String

<policyEntry> 元素

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

属性

属性名称

类型

描述

死信策略

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

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

destination

org.apache.activemq.command.ActiveMQDestination

调度策略

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

启用审计

boolean

最大审计深度

int

要审计的最大生产者数量

int

最大队列审计深度

int

内存限制

long

消息驱逐策略

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

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

消息组映射工厂

org.apache.activemq.broker.region.group.MessageGroupMapFactory

设置用于创建用于实现 消息组 功能的 {MessageGroupMap} 新实例的工厂。

优化调度

boolean

挂起的持久订阅者策略

org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy

挂起消息限制策略

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

设置策略以计算允许在消费者上挂起的最大消息数(除了它们的预取大小)。一旦达到限制,非持久主题就可以开始丢弃旧消息。这使我们能够将消息持续调度到慢速消费者,同时不阻止快速消费者并按最旧优先顺序丢弃消息。

挂起队列策略

org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy

挂起订阅者策略

org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy

生产者流量控制

boolean

queue

java.lang.String

从配置文件设置目的地的辅助方法

如果没有消费者则发送咨询

boolean

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

订阅恢复策略

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)填充目的地映射

策略条目

(java.lang.Object)*

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

<prefetchPolicy> 元素

定义不同类型消费者的预取邮件策略

属性

属性名称

类型

描述

全部

int

持久主题预取

int

输入流预取

int

最大挂起消息限制

int

设置代理在开始丢弃旧消息之前为非持久主题保留的消息数量,超出预取限制。

优化持久主题预取

int

队列浏览器预取

int

队列预取

int

主题预取

int

<prefetchRatePendingMessageLimitStrategy> 元素

此 PendingMessageLimitStrategy 将最大挂起邮件限制值设置为订阅预取限制的倍数。

属性

属性名称

类型

描述

乘数

双精度

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

<proxyConnector> 元素

属性

属性名称

类型

描述

绑定

java.net.URI

本地 URI

java.net.URI

name

java.lang.String

远程

java.net.URI

服务器

org.apache.activemq.transport.TransportServer

<queryBasedSubscriptionRecoveryPolicy> 元素

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

属性

属性名称

类型

描述

查询

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

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

<queue> 元素

一个 ActiveMQ Classic 队列

属性

属性名称

类型

描述

复合目标

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

name

java.lang.String

物理名称

java.lang.String

properties

java.util.Properties

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

<redeliveryPolicy> 元素

用于控制消息回滚时如何重新传递消息的配置选项。

属性

属性名称

类型

描述

后退乘数

短整型

避免冲突百分比

短整型

初始重新传递延迟

long

最大重新传递次数

int

使用避免冲突

boolean

使用指数后退

boolean

<roundRobinDispatchPolicy> 元素

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

<sharedDeadLetterStrategy> 元素

一个 {@link DeadLetterStrategy} 的默认实现,它使用恒定目的地。

属性

属性名称

类型

描述

死信队列

org.apache.activemq.command.ActiveMQDestination

processExpired

boolean

processNonPersistent

boolean

<simpleAuthenticationPlugin> 元素

提供一个简单的身份验证插件

属性

属性名称

类型

描述

用户组

java.util.Map

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

用户密码

java.util.Map

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

用户

(java.lang.Object)*

设置用于身份验证的各个用户

<simpleAuthorizationMap> 元素

一个使用每个操作的单个 DestinationMap 配置的 AuthorizationMap。

属性

属性名称

类型

描述

adminACLs

org.apache.activemq.filter.DestinationMap

readACLs

org.apache.activemq.filter.DestinationMap

tempDestinationAuthorizationEntry

org.apache.activemq.security.TempDestinationAuthorizationEntry

writeACLs

org.apache.activemq.filter.DestinationMap

<simpleDispatchPolicy> 元素

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

<simpleJmsMessageConvertor> 元素

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

属性

属性名称

类型

描述

connection

javax.jms.Connection

<simpleMessageGroupMapFactory> 元素

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

<statements> 元素

属性

属性名称

类型

描述

添加消息语句

java.lang.String

二进制数据类型

java.lang.String

容器名称数据类型

java.lang.String

创建持久订阅语句

java.lang.String

创建模式语句

(java.lang.String)*

删除旧消息语句

java.lang.String

删除订阅语句

java.lang.String

目标消息计数语句

java.lang.String

删除模式语句

(java.lang.String)*

持久订阅确认表名

java.lang.String

持久订阅者消息计数语句

java.lang.String

查找所有目标语句

java.lang.String

查找所有持久订阅消息语句

java.lang.String

查找所有持久订阅语句

java.lang.String

查找所有消息语句

java.lang.String

查找持久订阅消息语句

java.lang.String

查找持久订阅语句

java.lang.String

查找确认中的最后序列 ID 语句

java.lang.String

查找消息中的最后序列 ID 语句

java.lang.String

查找消息序列 ID 语句

java.lang.String

查找消息语句

java.lang.String

查找下一条消息语句

java.lang.String

最后确认的持久订阅者消息语句

java.lang.String

锁定创建语句

java.lang.String

锁定表名

java.lang.String

锁定更新语句

java.lang.String

长整型数据类型

java.lang.String

消息表名

java.lang.String

消息 ID 数据类型

java.lang.String

下一条持久订阅者消息语句

java.lang.String

删除所有消息语句

java.lang.String

删除所有订阅语句

java.lang.String

删除消息语句

java.lang.String

序列数据类型

java.lang.String

字符串 ID 数据类型

java.lang.String

表前缀

java.lang.String

更新持久订阅的最后确认语句

java.lang.String

更新消息语句

java.lang.String

useExternalMessageReferences

boolean

使用锁定创建 WHERE 子句

boolean

<storeCursor> 元素

挂起的邮件

<storeDurableSubscriberCursor> 元素

持久订阅者的挂起邮件

<storeUsage> 元素

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

属性

属性名称

类型

描述

limit

long

设置内存限制(以字节为单位)。使用字节设置限制将使用量部分设置为 0,因为 UsageManager 不会基于父项进行部分计算。使用 XBean 设置时,可以使用以下值:“20 mb”、“1024 kb”或“1 gb”

限制器

org.apache.activemq.usage.UsageCapacity

name

java.lang.String

父项

T

使用百分比

int

使用百分比最小增量

int

设置管理器触发 UsageListener 事件之前使用情况必须更改的最小百分比点数。

轮询时间

int

存储

org.apache.activemq.store.PersistenceAdapter

使用量部分

浮点数

<streamJDBCAdapter> 元素

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

  • Axion

属性

属性名称

类型

描述

batchStatments

boolean

statements

org.apache.activemq.store.jdbc.Statements

useExternalMessageReferences

boolean

<strictOrderDispatchPolicy> 元素

调度策略,使每个订阅以相同的顺序查看消息。

<systemUsage> 元素

内存、存储和临时文件的 Usage 实例的持有者 主要用例是管理内存使用情况。

属性

属性名称

类型

描述

adapter

org.apache.activemq.store.PersistenceAdapter

内存使用情况

org.apache.activemq.usage.MemoryUsage

name

java.lang.String

父项

org.apache.activemq.usage.SystemUsage

如果空间不足则发送失败

boolean

设置如果空间不足是否应使 send() 失败。默认值为 false,表示阻塞 send() 方法,直到空间可用为止

如果空间不足则显式设置发送失败

boolean

存储使用情况

org.apache.activemq.usage.StoreUsage

临时存储

org.apache.activemq.kaha.Store

临时使用情况

org.apache.activemq.usage.TempUsage

<tempDestinationAuthorizationEntry> 元素

表示 {@link DefaultAuthorizationMap} 中的条目,用于将用户角色的不同操作(读取、写入、管理)分配给临时目的地

属性

属性名称

类型

描述

admin

java.lang.String

adminACLs

(java.lang.Object)*

destination

org.apache.activemq.command.ActiveMQDestination

groupClass

java.lang.String

queue

java.lang.String

从配置文件设置目的地的辅助方法

read

java.lang.String

readACLs

(java.lang.Object)*

topic

java.lang.String

从配置文件设置目的地的辅助方法

write

java.lang.String

writeACLs

(java.lang.Object)*

<tempUsage> 元素

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

属性

属性名称

类型

描述

limit

long

设置内存限制(以字节为单位)。使用字节设置限制将使用量部分设置为 0,因为 UsageManager 不会基于父项进行部分计算。使用 XBean 设置时,可以使用以下值:“20 mb”、“1024 kb”或“1 gb”

限制器

org.apache.activemq.usage.UsageCapacity

name

java.lang.String

父项

T

使用百分比

int

使用百分比最小增量

int

设置管理器触发 UsageListener 事件之前使用情况必须更改的最小百分比点数。

轮询时间

int

存储

org.apache.activemq.kaha.Store

使用量部分

浮点数

<timeStampingBrokerPlugin> 元素

一个代理拦截器,使用代理时间戳更新 JMS 客户端的邮件时间戳。当客户端机器上的时钟已知不正确,并且您只能信任代理机器上设置的时间时,这很有用。启用此插件将破坏 JMS 兼容性,因为生产者在发送后看到的邮件上的时间戳将不同于消费者接收邮件时观察到的时间戳。此插件在默认 ActiveMQ Classic 配置中未启用。

属性

属性名称

类型

描述

管理员连接上下文

org.apache.activemq.broker.ConnectionContext

下一个

org.apache.activemq.broker.Broker

<timedSubscriptionRecoveryPolicy> 元素

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

属性

属性名称

类型

描述

恢复持续时间

long

<topic> 元素

一个 ActiveMQ Classic 主题

属性

属性名称

类型

描述

复合目标

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

name

java.lang.String

物理名称

java.lang.String

properties

java.util.Properties

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

<transportConnector> 元素

属性

属性名称

类型

描述

代理

org.apache.activemq.broker.Broker

代理信息

org.apache.activemq.command.BrokerInfo

brokerName

java.lang.String

连接 URI

java.net.URI

禁用异步调度

boolean

发现代理

org.apache.activemq.transport.discovery.DiscoveryAgent

发现 URI

java.net.URI

启用状态监控器

boolean

messageAuthorizationPolicy

org.apache.activemq.security.MessageAuthorizationPolicy

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

name

java.lang.String

服务器

org.apache.activemq.transport.TransportServer

taskRunnerFactory

org.apache.activemq.thread.TaskRunnerFactory

URI

java.net.URI

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

<udpTraceBrokerPlugin> 元素

一个代理拦截器,允许您将所有操作跟踪到 UDP 套接字。

属性

属性名称

类型

描述

地址

java.net.SocketAddress

管理员连接上下文

org.apache.activemq.broker.ConnectionContext

广播

boolean

destination

java.net.URI

最大跟踪数据报大小

int

下一个

org.apache.activemq.broker.Broker

wireFormat

org.apache.activemq.wireformat.WireFormat

线格式工厂

org.apache.activemq.wireformat.WireFormatFactory

<usageCapacity> 元素

识别是否已达到限制

属性

属性名称

类型

描述

limit

long

<virtualDestinationInterceptor> 元素

实现 虚拟主题

属性

属性名称

类型

描述

虚拟目标

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

<virtualTopic> 元素

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

属性

属性名称

类型

描述

name

java.lang.String

后缀

java.lang.String

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

前缀

java.lang.String

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

<vmCursor> 元素

挂起的邮件保留

<vmDurableCursor> 元素

挂起

<vmQueueCursor> 元素

挂起的邮件

<xaConnectionFactory> 元素

一个经过 Spring 增强的 XA 连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

属性

属性名称

类型

描述

alwaysSessionAsync

boolean

如果设置了此标志,则不会为连接中的每个会话使用单独的线程来调度消息。但是,如果有多个会话,或者会话不在自动确认或重复确认模式下,则始终使用单独的线程

alwaysSyncSend

boolean

如果始终需要消息进行同步发送,则设置为 true

beanName

java.lang.String

blobTransferPolicy

org.apache.activemq.blob.BlobTransferPolicy

设置用于描述如何将带外 BLOB(二进制大对象)从生产者传输到代理再到消费者的策略

brokerURL

java.lang.String

设置用于连接到 ActiveMQ Classic 代理的 连接 URL

clientID

java.lang.String

设置要为创建的连接使用的 JMS clientID。请注意,这只能被一个连接使用一次,因此通常最好在连接上设置 clientID

clientIDPrefix

java.lang.String

设置自动生成的 JMS 客户端 ID 值使用的前缀,这些值在 JMS 客户端未明确指定的情况下使用。

clientIdGenerator

org.apache.activemq.util.IdGenerator

closeTimeout

int

设置关闭操作完成之前的时间超时。通常,连接上的 close() 方法等待来自代理的确认;这允许该操作超时,以防止客户端在没有代理的情况下挂起

copyMessageOnSend

boolean

JMS 消息是否应作为 JMS 中 send() 方法的一部分被复制到新的 JMS 消息对象。默认情况下启用此功能,以符合 JMS 规范。如果在发送 JMS 消息后不修改它们,则可以禁用它以提高性能

disableTimeStampsByDefault

boolean

设置消息上的时间戳是否应禁用。如果禁用它们,则会略微提高性能。

dispatchAsync

boolean

启用或禁用消费者是否由代理 同步或异步调度 消息的默认设置。例如,对于非持久主题,我们通常默认情况下同步调度,以最大程度地减少上下文切换,从而提高性能。但是,有时最好放慢速度,以确保单个阻塞的消费者套接字不会阻止消息传递到其他消费者。

exclusiveConsumer

boolean

启用或禁用队列消费者是否应该是排他的,例如,在不使用 消息组 的情况下保留排序

nestedMapAndListEnabled

boolean

启用/禁用消息属性和 MapMessage 条目是否支持 Map 和 List 对象的嵌套结构

objectMessageSerializationDefered

boolean

当在 ObjectMessage 上设置对象时,JMS 规范要求该对象通过该 set 方法序列化。启用此标志会导致对象不进行序列化。如果需要通过套接字发送消息或将其存储到磁盘,则该对象可能会随后进行序列化。

optimizeAcknowledge

boolean

optimizedMessageDispatch

boolean

如果设置了此标志,则使用更大的预取限制 - 仅适用于持久主题订阅者。

password

java.lang.String

设置从该工厂创建的连接使用的 JMS 密码

prefetchPolicy

org.apache.activemq.ActiveMQPrefetchPolicy

设置由该连接创建的消费者的 预取策略

producerWindowSize

int

properties

java.util.Properties

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

redeliveryPolicy

org.apache.activemq.RedeliveryPolicy

设置在消息传递但会话回滚时要使用的全局重新传递策略

statsEnabled

boolean

transformer

org.apache.activemq.MessageTransformer

设置在将消息发送到 JMS 总线之前或从总线接收它们但将其传递到 JMS 客户端之前对其进行转换的转换器

transportListener

org.apache.activemq.transport.TransportListener

允许在 ConnectionFactory 上配置一个监听器,以便当此工厂与不公开连接的框架(例如 Spring JmsTemplate)一起使用时,您仍然可以注册传输监听器。

useAsyncSend

boolean

强制使用 异步发送,这会大幅提高性能;但这意味着 send() 方法将立即返回,无论消息是否已发送,这可能会导致消息丢失。

useBeanNameAsClientIdPrefix

boolean

useCompression

boolean

启用消息体的压缩使用

useRetroactiveConsumer

boolean

设置是否启用追溯消费者。追溯消费者允许非持久主题订阅者接收在非持久订阅者启动之前发布的旧消息。

userName

java.lang.String

设置由该工厂创建的连接使用的 JMS 用户名

warnAboutUnstartedConnectionTimeout

long

启用从连接创建到生成警告之间的超时,如果连接未通过 {@link Connection#start()} 正确启动并且消费者接收到消息。忘记 启动连接 是一个非常常见的错误,因此此选项使默认情况下会在用户忘记的情况下创建警告。要禁用警告,只需将值设置为 < 0(例如 -1)。

watchTopicAdvisories

boolean

元素索引

<amqPersistenceAdapter>

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

<amqPersistenceAdapterFactory>

{@link PersistenceAdapterFactory} 的一个实现

<authenticationUser>

用于配置简单身份验证插件的辅助对象

<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 驱动程序是

<commandAgent>

一个在 JMS 目的地上监听命令的代理

<compositeDemandForwardingBridge>

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

<compositeQueue>

表示将转发到多个其他目的地的虚拟队列。

<compositeTopic>

表示将转发到多个其他目的地的虚拟主题。

<connectionDotFilePlugin>

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

<connectionFactory>

一个经过 Spring 增强的连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

<constantPendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 被配置为对所有订阅的常数值。

<db2JDBCAdapter>

<defaultJDBCAdapter>

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

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

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

使用此适配器的数据库/JDBC 驱动程序是

<defaultUsageCapacity>

识别是否已达到限制

<demandForwardingBridge>

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

<destinationDotFilePlugin>

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

<destinationEntry>

DestinationMap 中的默认条目,它保存单个值。

<fileCursor>

挂起的邮件

<fileDurableSubscriberCursor>

持久订阅者的挂起邮件

<fileQueueCursor>

挂起

<filteredDestination>

表示使用某些谓词(例如选择器)进行过滤的目标,以便只有与过滤器匹配的消息才会被调度到目标。

<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 个字符。因此,请确保不要使用超过 150 个字符的容器名称和订阅 ID。

<jaasAuthenticationPlugin>

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

<jaasCertificateAuthenticationPlugin>

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

<jdbcPersistenceAdapter>

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

<jmsQueueConnector>

一个连接到其他 JMS 队列提供程序的桥

<jmsTopicConnector>

一个连接到其他 JMS 主题提供程序的桥

<journalPersistenceAdapter>

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

<journaledJDBC>

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

<kahaPersistenceAdapter>

<lDAPAuthorizationMap>

一个使用 LDAP 的 {@link AuthorizationMap}

<lastImageSubscriptionRecoveryPolicy>

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

<ldapNetworkConnector>

类用于创建使用 LDAP v3 协议(如 RFC 2251 中定义)在目录服务器中列出的动态网络连接器,目录服务器中列出的条目必须实现 RFC 2307 中定义的 ipHost 和 ipService 对象类。

<loggingBrokerPlugin>

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

<managementContext>

流在 NMR 中提供不同的调度策略

<masterConnector>

使用 主从 来实现消息的高可用性时,将从属代理连接到主代理。

<memoryPersistenceAdapter>

<memoryUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

<messageGroupHashBucketFactory>

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

<mirroredQueue>

使用前缀和后缀创建 镜像队列,以定义要镜像队列的主题名称。

<multicastNetworkConnector>

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

<multicastTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到多播套接字。

<networkConnector>

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

<noSubscriptionRecoveryPolicy>

此 SubscriptionRecoveryPolicy 禁用邮件恢复。

<oldestMessageEvictionStrategy>

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

<oldestMessageWithLowestPriorityEvictionStrategy>

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

<oracleJDBCAdapter>

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

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

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

使用此适配器的数据库/JDBC 驱动程序是

<outboundQueueBridge>

创建一个出站队列桥

<outboundTopicBridge>

创建一个出站主题桥

<policyEntry>

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

<policyMap>

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

<prefetchPolicy>

定义不同类型消费者的预取邮件策略

<prefetchRatePendingMessageLimitStrategy>

此 PendingMessageLimitStrategy 将最大挂起邮件限制值设置为订阅预取限制的倍数。

<proxyConnector>

<queryBasedSubscriptionRecoveryPolicy>

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

<queue>

一个 ActiveMQ Classic 队列

<redeliveryPolicy>

用于控制消息回滚时如何重新传递消息的配置选项。

<roundRobinDispatchPolicy>

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

<sharedDeadLetterStrategy>

一个 {@link DeadLetterStrategy} 的默认实现,它使用恒定目的地。

<simpleAuthenticationPlugin>

提供一个简单的身份验证插件

<simpleAuthorizationMap>

一个使用每个操作的单个 DestinationMap 配置的 AuthorizationMap。

<simpleDispatchPolicy>

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

<simpleJmsMessageConvertor>

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

<simpleMessageGroupMapFactory>

一个工厂,用于在实现 消息组 功能时创建 {@link SimpleMessageGroupMap} 的实例。

<statements>

<storeCursor>

挂起的邮件

<storeDurableSubscriberCursor>

持久订阅者的挂起邮件

<storeUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

<streamJDBCAdapter>

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

  • Axion

<strictOrderDispatchPolicy>

调度策略,使每个订阅以相同的顺序查看消息。

<systemUsage>

内存、存储和临时文件的 Usage 实例的持有者 主要用例是管理内存使用情况。

<tempDestinationAuthorizationEntry>

表示 {@link DefaultAuthorizationMap} 中的条目,用于将用户角色的不同操作(读取、写入、管理)分配给临时目的地

<tempUsage>

用于跟踪正在使用多少东西,以便可以控制生产性工作集使用情况。主要用例是管理内存使用情况。

<timeStampingBrokerPlugin>

一个代理拦截器,使用代理时间戳更新 JMS 客户端的邮件时间戳。当客户端机器上的时钟已知不正确,并且您只能信任代理机器上设置的时间时,这很有用。启用此插件将破坏 JMS 兼容性,因为生产者在发送后看到的邮件上的时间戳将不同于消费者接收邮件时观察到的时间戳。此插件在默认 ActiveMQ Classic 配置中未启用。

<timedSubscriptionRecoveryPolicy>

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

<topic>

一个 ActiveMQ Classic 主题

<transportConnector>

<udpTraceBrokerPlugin>

一个代理拦截器,允许您将所有操作跟踪到 UDP 套接字。

<usageCapacity>

识别是否已达到限制

<virtualDestinationInterceptor>

实现 虚拟主题

<virtualTopic>

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

<vmCursor>

挂起的邮件保留

<vmDurableCursor>

挂起

<vmQueueCursor>

挂起的邮件

<xaConnectionFactory>

一个经过 Spring 增强的 XA 连接工厂,它将自动使用 Spring bean 名称作为 clientIDPrefix 属性,以便创建的连接具有与 Spring.xml 文件相关的客户端 ID,以便从 JMX 更容易理解。

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