rabbitmq-client base spring-rabbit and spring-amqp

基于spring-amqp的rabbitmq客户端

构建安装

使用maven构建

git clone https://github.com/hashio/websocket-client.git
cd rabbitmq-client
mvn clean install

<dependency>
 <groupId>me.poplaris</groupId>
 <artifactId>rabbitmq-client</artifactId>
 <version>1.0</version>
</dependency>

用法

class ApiProcessEventProcessor implements EventProcesser{
 @Override
 public void process(Object e) {//消费程序这里只是打印信息
 System.out.println(e);
 }
}

String defaultHost = "127.0.0.1";
String defaultExchange = "EXCHANGE_DIRECT_TEST";
String defaultQueue = "QUEUE_TEST";
EventControlConfig config = new EventControlConfig(defaultHost);
DefaultEventController controller = DefaultEventController.getInstance(config);
EventTemplate eventTemplate = controller.getEopEventTemplate();
controller.add(defaultQueue, defaultExchange, new ApiProcessEventProcessor());
controller.start();

eventTemplate.send(defaultQueue, defaultExchange, "hello world");

eventTemplate.send(defaultQueue, defaultExchange, mockObj());