public class ActiveMQTxMessageProducer extends AbsActiveMQTxMessageProducer { private QMessageService qMessageService; public QMessageService getqMessageService() { return qMessageService; } public void setqMessageService(QMessageService qMessageService) { this.qMessageService = qMessageService; } /** * 事务消息处理成功后的处理 * 事务消息处理成功,从消息表中删除对应的消息 * * @param messageId 消息id */ public void onSuccess(String messageId) { log.info("tx message--{}--commit success", messageId); //事务消息处理成功后,删除数据库中对应的消息 qMessageService.deleteQMessage(messageId); } /** * 事务消息处理失败后的处理 * 事务消息处理失败户,进行日志相关记录 * 或者其他相关数据库操作 * * @param e 消息发送异常 * @param messageId 消息id */ public void onFail(Exception e, String messageId) { log.error("send tx message:{} ,error:{}", messageId, e.getMessage()); } public ActiveMQTxMessageProducer() { } public ActiveMQTxMessageProducer(Builder builder) { this.brokerUrl = builder.brokerUrl; this.userName = builder.userName; this.password = builder.password; this.destName = builder.destName; this.n2 = builder.n2; this.qMessageService = builder.qMessageService; } public static Builder builder() { return new Builder(); } public static class Builder { private String brokerUrl; private String userName; private String password; private String destName; private boolean n2; private QMessageService qMessageService; public Builder() { } public Builder brokerUrl(String brokerUrl) { this.brokerUrl = brokerUrl; return this; } public Builder userName(String userName) { this.userName = userName; return this; } public Builder password(String password) { this.password = password; return this; } public Builder destName(String destName) { this.destName = destName; return this; } public Builder n2(boolean n2) { this.n2 = n2; return this; } public Builder qMessageService(QMessageService qMessageService) { this.qMessageService = qMessageService; return this; } public ActiveMQTxMessageProducer build() throws Exception { ActiveMQTxMessageProducer producer = new ActiveMQTxMessageProducer(this); producer.afterPropertiesSet(); return producer; } } }
调用:
//启动时初始化生产者 ActiveMQTxMessageProducer producer = producerCache.get(destName); if (producer == null) { producer = ActiveMQTxMessageProducer.builder() .brokerUrl(brokerConfig.getBrokerUrl()) .userName(brokerConfig.getUserName()) .password(brokerConfig.getPassword()) .destName(destName) .n2(n2) .qMessageService(qMessageService) .build(); //加入缓存中 producerCache.set(destName, producer); }
相关推荐
### Java静态内部类(嵌套类)详解 #### 一、静态内部类概念与特性 在Java编程语言中,静态内部类(也被称为嵌套类)是一种特殊的内部类形式,它通过`static`关键字来定义。与普通内部类相比,静态内部类具有以下...
15.java静态内部类(相当于外部类).zip15.java静态内部类(相当于外部类).zip15.java静态内部类(相当于外部类).zip15.java静态内部类(相当于外部类).zip15.java静态内部类(相当于外部类).zip15.java静态内部...
Java语言中的静态内部类,也称为嵌套类,是内部类的一种特殊形式,它与非静态内部类(也称为成员内部类)相比有着独特的特点和使用场景。在深入探讨其使用规范之前,我们先理解静态内部类的基本概念。 静态内部类不...
Java内部类是Java语言中一个独特且强大的特性,它允许我们在一个类的内部定义另一个类。内部类可以分为四种类型:静态内部类、成员内部类(非静态内部类)、局部内部类和匿名内部类。 1. **静态内部类**: 静态...
Java中的静态内部类详解及代码示例 Java中的静态内部类是一种特殊的内部类,它可以独立于外部类存在,具有自己的生命周期。静态内部类的定义形式如下: public class OuterClass { static class StaticInnerClass...
静态内部类(Static Inner Class)是在Java中一种特殊的内部类实现形式。在Java编程语言中,内部类允许在一个类的内部定义另一个类。根据内部类是否声明为static,它们被分为非静态内部类(也称为成员内部类)和静态...
Java内部类是一种定义在另一个类内部的类,它可以访问外部类的所有成员,包括私有成员。内部类分为四种类型:成员内部类、局部内部类、匿名内部类和静态嵌套类。其中,静态嵌套类是与外部类关联但不持有对外部类的...
总之,内部类和静态内部类是Java中独特的类设计方式,它们提供了灵活的代码组织和访问控制手段。成员内部类适合处理需要紧密关联的情况,而静态内部类则适用于实现工具类或辅助功能,并且在单例模式中有独特的优势。...
Java中的静态内部类(Static Class),也称为嵌套静态类,是Java语言提供的一种独特机制,它允许我们在一个外部类内部定义一个静态的类。这种类的声明前面带有`static`关键字,与普通的内部类(非静态内部类)有所...
- 不同类型的内部类(静态内部类、成员内部类、局部内部类和匿名内部类)的区别和用法 - 内部类的优缺点以及使用场景 这些目标将帮助你理解和掌握内部类的概念,并能够在适当的时候使用内部类来解决问题...
本文详细介绍了 Java 中内部类的各种类型及其使用场景,包括静态内部类、非静态内部类、局部内部类以及匿名内部类。每种类型的内部类都有其独特的特性和应用场景,理解这些差异对于更高效地利用 Java 语言特性至关...
"Java单例模式实现静态内部类方法示例" Java单例模式是软件设计模式中最基本和最常见的一种设计模式,也是最容易理解的一种设计模式。它的主要思想是确保某个类只有一个实例,并且提供一个全局访问点来访问该实例。...
Java SE中的静态内部类是一种特殊的内部类,它与非静态内部类(也称为成员内部类)有着显著的区别。静态内部类并不需要外部类的实例来创建它的对象,而是可以直接通过类名进行实例化,就像普通的类一样。在给定的...
Java内部类应用之静态内部类应用示例 Java内部类应用之静态内部类应用示例主要介绍了Java内部类应用之静态内部类应用,结合实例形式分析了Java静态内部类的原理、功能、用法及相关操作注意事项。 一、静态内部类的...
Java成员内部类是一种在类内部定义的类,它可以访问外部类的所有成员,包括私有成员。成员内部类的使用在Java编程中具有独特的价值,它能够帮助我们更好地封装代码,提高代码的组织性和可读性。以下是关于Java成员...
内部类主要分为四种类型:静态内部类、成员内部类、局部内部类和匿名内部类。 1. 静态内部类(Static Inner Class) 静态内部类与普通的类类似,只是它们定义在外部类中,并且前面带有 `static` 关键字。它们不会...
然而,不当使用Handler,尤其是结合匿名内部类或非静态内部类,可能导致内存泄漏和Native内存增加,这对应用性能和稳定性造成负面影响。 首先,我们要理解内存泄漏的概念。内存泄漏是指程序中已分配的内存没有被...
Java匿名内部类是Java语言中一个独特且强大的特性,它允许我们在不需要定义一个单独的类的情况下创建类的实例。这在处理回调、事件监听、单例模式以及其他需要短时间内定义一个简单类的情况时非常有用。本篇文章将...
Java内部类 Java内部类是Java编程语言中的一种特殊的类,它定义在另一个类的内部。内部类可以访问外部类的成员变量和成员方法,同时也可以被外部类访问。内部类可以分为非静态内部类、局部内部类、静态内部类和匿名...
在Java编程中,静态代码块(Static Block)和类加载器(Class Loader)是两个重要的概念,它们在软件开发中有着广泛的应用。本案例聚焦于如何利用静态代码块结合类加载器来高效地获取资源文件,尤其是属性配置文件。...