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 更容易理解。