com.actionsoft.sdk.local.api.cc

接口 RabbitmqAPI

所有超级接口:

java.lang.AutoCloseable, java.io.Closeable

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)

从接口继承的方法 java.io.Closeable

close

字段详细资料

direct

static final java.lang.String direct

另请参阅:

常量字段值

topic

static final java.lang.String topic

另请参阅:

常量字段值

fanout

static final java.lang.String fanout

另请参阅:

常量字段值

headers

static final java.lang.String headers

另请参阅:

常量字段值

queue

static final java.lang.String queue

另请参阅:

常量字段值

方法详细资料

doIn

void doIn(<any> f)
   throws java.lang.Exception

抛出:

java.lang.Exception

publish

void publish(java.lang.String name,
             byte[] body)
      throws java.io.IOException,
             java.util.concurrent.TimeoutException

发送一条queue消息

参数:

name - Queue name

message - string消息

抛出:

java.io.IOException

java.util.concurrent.TimeoutException

publish

void publish(java.lang.String name,
             java.lang.String type,
             byte[] body)
      throws java.io.IOException,
             java.util.concurrent.TimeoutException

发送一条消息

参数:

name - queue name或exchange name

type - queue|fanout|topic|headers|direct

body - 消息内容

抛出:

java.io.IOException

java.util.concurrent.TimeoutException

publish

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

consume

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 name

type - queue|fanout|topic|headers|direct

listener - DeliverCallback监听器

返回:

the consumerTag generated by the server

抛出:

java.io.IOException

java.util.concurrent.TimeoutException

consume

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 binding

autoAck -

listener -

返回:

the consumerTag generated by the server

抛出:

java.io.IOException

java.util.concurrent.TimeoutException

consume

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 name

type - queue|fanout|topic|headers|direct

autoAck - 是否自动确认

listener - DeliverCallback监听器

返回:

the consumerTag generated by the server

抛出:

java.io.IOException

java.util.concurrent.TimeoutException