| 限定符和类型 | 方法和说明 |
|---|---|
static Jbootmq |
Jboot.getMq()
获取 Mq
|
static Jbootmq |
Jboot.getMq(String name)
获取指定的 MQ
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootmqBase |
| 限定符和类型 | 字段和说明 |
|---|---|
(专用程序包) Jbootmq |
MessageContext.mq |
| 限定符和类型 | 字段和说明 |
|---|---|
private Map<String,Jbootmq> |
JbootmqManager.jbootmqMap |
| 限定符和类型 | 方法和说明 |
|---|---|
private Jbootmq |
JbootmqManager.buildJbootmq(JbootmqConfig config) |
Jbootmq |
JbootmqManager.getJbootmq() |
Jbootmq |
JbootmqManager.getJbootmq(JbootmqConfig config) |
Jbootmq |
JbootmqManager.getJbootmq(String name) |
Jbootmq |
MessageContext.getMq() |
| 构造器和说明 |
|---|
MessageContext(Jbootmq mq) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootActivemq |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootAliyunmqImpl |
| 构造器和说明 |
|---|
AliyunmqMessageContext(Jbootmq mq,
com.aliyun.openservices.ons.api.Message orginalMessage,
com.aliyun.openservices.ons.api.ConsumeContext context) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootLocalmqImpl |
| 构造器和说明 |
|---|
LocalmqMessageContext(Jbootmq mq) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootQpidmqImpl |
| 构造器和说明 |
|---|
QpidmqMessageContext(Jbootmq mq,
javax.jms.Message orignalMessage) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootRabbitmqImpl
doc : http://www.rabbitmq.com/api-guide.html
|
| 构造器和说明 |
|---|
RabbitmqMessageContext(Jbootmq mq,
com.rabbitmq.client.Channel channel,
String consumerTag,
com.rabbitmq.client.Envelope envelope,
com.rabbitmq.client.AMQP.BasicProperties properties) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootRedismqImpl |
| 构造器和说明 |
|---|
RedismqMessageContext(Jbootmq mq) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
JbootRocketmqImpl |
| 构造器和说明 |
|---|
RokectmqMessageContext(Jbootmq jbootmq,
List<org.apache.rocketmq.common.message.MessageExt> msgs,
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context) |
Copyright © 2024. All rights reserved.