public interface RabbitmqAPI
extends java.io.Closeable
支持日志和审计的操作包括:doIn、publish、consume
限定符和类型 | 字段和说明 |
---|---|
static java.lang.String |
direct |
static java.lang.String |
fanout |
static java.lang.String |
headers |
static java.lang.String |
queue |
static java.lang.String |
topic |
限定符和类型 | 方法和说明 |
---|---|
java.lang.String |
consume(java.lang.String name,
java.lang.String type,
boolean autoAck,
DeliverCallback listener)
设置消费者监听
|
java.lang.String |
consume(java.lang.String name,
java.lang.String type,
DeliverCallback listener)
设置消费者监听
|
java.lang.String |
consume(java.lang.String name,
java.lang.String type,
java.lang.String routingKey,
boolean autoAck,
DeliverCallback listener)
设置消费者监听
|
void |
doIn(<any> f) |
void |
publish(java.lang.String name,
byte[] body)
发送一条queue消息
|
void |
publish(java.lang.String name,
java.lang.String type,
byte[] body)
发送一条消息
|
void |
publish(java.lang.String name,
java.lang.String type,
java.lang.String routingKey,
byte[] body) |
static final java.lang.String direct
static final java.lang.String topic
static final java.lang.String fanout
static final java.lang.String headers
static final java.lang.String queue
void doIn(<any> f) throws java.lang.Exception
java.lang.Exception
void publish(java.lang.String name, byte[] body) throws java.io.IOException, java.util.concurrent.TimeoutException
name
- Queue namemessage
- string消息java.io.IOException
java.util.concurrent.TimeoutException
void publish(java.lang.String name, java.lang.String type, byte[] body) throws java.io.IOException, java.util.concurrent.TimeoutException
name
- queue name或exchange nametype
- queue|fanout|topic|headers|directbody
- 消息内容java.io.IOException
java.util.concurrent.TimeoutException
void publish(java.lang.String name, java.lang.String type, java.lang.String routingKey, byte[] body) throws java.io.IOException, java.util.concurrent.TimeoutException
java.io.IOException
java.util.concurrent.TimeoutException
java.lang.String consume(java.lang.String name, java.lang.String type, DeliverCallback listener) throws java.io.IOException, java.util.concurrent.TimeoutException
name
- Queue name|exchange nametype
- queue|fanout|topic|headers|directlistener
- DeliverCallback监听器java.io.IOException
java.util.concurrent.TimeoutException
java.lang.String consume(java.lang.String name, java.lang.String type, java.lang.String routingKey, boolean autoAck, DeliverCallback listener) throws java.io.IOException, java.util.concurrent.TimeoutException
name
- type
- routingKey
- the routing key to use for the bindingautoAck
- listener
- java.io.IOException
java.util.concurrent.TimeoutException
java.lang.String consume(java.lang.String name, java.lang.String type, boolean autoAck, DeliverCallback listener) throws java.io.IOException, java.util.concurrent.TimeoutException
name
- Queue name|exchange nametype
- queue|fanout|topic|headers|directautoAck
- 是否自动确认listener
- DeliverCallback监听器java.io.IOException
java.util.concurrent.TimeoutException
Copyright © Actionsoft Co., Ltd. All Rights Reserved.