Install

• add dependencies into pom.xml

<dependency>
    <groupId>cc.voox</groupId>
    <artifactId>publisher</artifactId>
    <version>2.0.0</version>
</dependency>

• add config into spring.xml file

<ctx:component-scan base-package="cc.voox" />

<bean id="amqpConfig" class="AMQPConfig">
    <property name="host" value="localhost"/>
    <property name="port" value="5672"/>
    <property name="username" value="root" />
    <property name="password" value="123456"/>
    <property name="virtualHost" value="/mytest" />
    <property name="prefixQueue" value="crm.api.test.queue"/>
    <property name="prefixExchange" value="crm.api.test.exchange"/>
    <property name="brokerUser" value="xs66@qq.cc"/>
    <property name="messageTTL" value="20000"/>
    <property name="path" value="com.testpackage"/>
</bean>

• OR add config into java bean

@ComponentScan("cc.voox")
@Configuration
public class QueueConfig {
    @Bean
    public AMQPConfig amqpConfig() {
        AMQPConfig config = new AMQPConfig();
        config.setHost("localhost");
        config.setPort(5672);
        config.setUsername("root");
        config.setPassword("123456");
        config.setVirtualHost("/mytest");
        config.setPrefixQueue("crm.api.test.queue");
        config.setPrefixExchange("crm.api.test.exchange");
        config.setBrokerUser("xs66@qq.cc");
        config.setMessageTTL(20000);
        config.setPath("com.testpackage");
        return config;
    }
}

Usage

• implements interface IMsg in entity class

public interface IMsg {
 String getPublishMsg();
}

• use @Pub in entity class

@Pub
class Item {

}

• publish msg to broker

@Service
class TestService {
    
    @Autowired 
    private Publisher publisher;
    public void addCustomer(Customer customer) {
       publisher.publish(customer);
    }
}