问题：

WSO2 Message Broker事务回滚

红智鑫

2023-03-14

1）最大重送次数

2）每次重发尝试之间的时间

我将在哪里进行这些配置，在我的{ESB_HOME}/repository/conf/axis2/axis2.xml文件中或在我的Message Broker中。

   <!--Uncomment this and configure as appropriate for JMS transport support with WSO2 MB 2.x.x -->
    <transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
        <parameter name="myTopicConnectionFactory" locked="false">
           <parameter name="java.naming.factory.initial" locked="false">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
            <parameter name="java.naming.provider.url" locked="false">repository/conf/jndi.properties</parameter>
            <parameter name="transport.jms.SessionTransacted">true</parameter>
            <parameter name="transport.jms.SessionAcknowledgement" locked="true">CLIENT_ACKNOWLEDGE</parameter>
           <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">TopicConnectionFactory</parameter>
            <parameter name="transport.jms.ConnectionFactoryType" locked="false">topic</parameter>
        </parameter>

        <parameter name="myQueueConnectionFactory" locked="false">
            <parameter name="java.naming.factory.initial" locked="false">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
            <parameter name="java.naming.provider.url" locked="false">repository/conf/jndi.properties</parameter>
            <parameter name="transport.jms.SessionTransacted">true</parameter>
            <parameter name="transport.jms.SessionAcknowledgement" locked="true">CLIENT_ACKNOWLEDGE</parameter>
              <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
           <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter>
        </parameter>

        <parameter name="default" locked="false">
            <parameter name="java.naming.factory.initial" locked="false">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
            <parameter name="java.naming.provider.url" locked="false">repository/conf/jndi.properties</parameter>
            <parameter name="transport.jms.SessionTransacted">true</parameter>
            <parameter name="transport.jms.SessionAcknowledgement" locked="true">CLIENT_ACKNOWLEDGE</parameter>
             <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
            <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter>
        </parameter>
    </transportReceiver>

<maximumNumberOfMessageDeliveryAttempts>10</maximumNumberOfMessageDeliveryAttempts>

<parameter name="redeliveryPolicy.redeliveryDelay" locked="true">1200000</parameter>

我想在WSO2 Message Broker中使用同样的功能，但找不到任何配置。我尝试了上面提到的参数，但它不适用于WSO2 MB。

共有1个答案

韶宏邈

2023-03-14

正如我所知，在WSO2 MB的情况下不能这样做。您必须设置一个消息存储区，并在该消息存储区上设置一个消息处理器。当您有消息处理器时，可以使用间隔和最大传递尝试次数来配置它。

https://docs.wso2.com/display/integrationpatterns/dead+letter+channel
http://charith.wickramaarachchi.org/2012/05/thera-message-redelivery-pattern-with.html
http://wso2.org/library/articles/2011/10/implementing-store-forward-messaging-patterns-wso2esb-part-1
http://wso2.com/library/articles/2011/12/implementing-store-forward-messaging-patterns-wso2esb-part-2/

（或者，您可以设置maxAckWaitTime，这意味着它将在两次重新传递尝试之间至少等待“最大AckWaittime”秒）

类似资料：

EJB3事务回滚

问题内容：我在EJB3无状态会话Bean中使用CMT。另外，我还创建了自己的具有注释“ @ApplicationException（rollback = true）”的异常。要回滚事务时是否必须使用“ context.setRollbackOnly（）”？我可以通过在bean的public方法内抛出异常来回滚事务吗？如果是这样（对Q＃2的回答是“是”），我是否必须通过在方法中声明异常来将异
@test后回滚事务

我正在使用spring-test运行JUnit测试，我的代码如下所示我的问题是我希望我的测试不影响其他测试。所以我想为每个测试创建一些类似回滚的东西。我为此找了很多，但到目前为止一无所获。我使用Hibernate和MySql来实现这个
Spring Boot事务回滚

-ZJ 以下是我在Application.Properties中的数据源设置：
Javers不回滚事务

我在Spring Boot应用程序中有一个Javers实现。Mongo4.4被用作数据库。从MongoDB4.4开始，您可以在事务中创建文档。我在创建对象时模拟了一个异常。如预期的那样，对象没有在数据库中创建，但是一个新的快照被添加到jv_snapshots集合中。控制器：
事务的强制回滚导致嵌套事务也回滚？

情景故事时间: 我“继承”了一个程序，一个用于访问数据库的相当简单的webservice。该程序在某个地方有一个缺陷：它试图更新一个没有更新授权的表。该程序只具有更新数据库队列的权限（Oracle）,以保存谁访问了什么信息。这是不受欢迎的行为，现在我纠正了它。注意：这与这个问题本身无关，它只是导致我提出这个问题的原因。该程序使用Spring+Hibernate来管理和访问数据和事务。因为程序的
事务回滚时Spring返回null

你能告诉我如何只对某些代码块运行事务吗？我有@Transactional的服务函数，并从它们调用存储库函数，在那里执行查询。但当查询失败时，由于事务必须结束，服务功能也随之失效。那么，当存储库函数失败时，如何返回null值呢？我需要在失败时捕获空值，并继续一些逻辑。我的代码：我尝试了@davidxxx的答案，得到了这个错误：
在Grails服务中回滚事务

问题内容：当服务中抛出RuntimeException时，我使用Grail的回滚功能将所有服务更新为事务性。在大多数情况下，我都这样做：无论如何，我想验证这是否确实会回滚事务……这让我开始思考是否在这一点上已经提交了。此外，如果没有，设置flush：true会改变这一点吗？我对Spring / Hibernate如何完成所有这些工作不是很熟悉：）问题答案：是的，那样做。默认情况下，Gra
Hibernate save（）和事务回滚

问题内容：在Hibernate中，当我在事务中有一个对象，然后回滚它时，保存的对象仍保留在DB中。奇怪，因为使用or 方法不会发生此问题，而只会使用。这是我正在使用的代码：这是 HibernateUtil 类（只是涉及的函数，我保证该方法能正常工作- 有一个Interceptor处理程序，但现在不重要了）：谢谢问题答案：检查数据库是否支持回滚，即是否使用的是InnoDB表而不是MyIS

WSO2 Message Broker事务回滚

共有1个答案

相关问答

相关文章

相关阅读

相关工具

相关文档