xin.alum.aim.rocketmq

类 RocketMQConfig

java.lang.Object

xin.alum.aim.rocketmq.RocketMQConfig

@ConditionalOnProperty(prefix="alum.aim.cluster",
                       name="mode",
                       havingValue="rocketmq")
public class RocketMQConfig
extends Object

字段概要

字段

限定符和类型	字段和说明
String	accessKey
String	consumerGroup
String	proxy
String	secretKey
static String	TAG_KILL
String	topic

构造器概要

构造器

构造器和说明
RocketMQConfig()

方法概要

限定符和类型	方法和说明
org.apache.rocketmq.client.apis.ClientServiceProvider	clientServiceProvider()
org.apache.rocketmq.client.apis.ClientConfiguration	configuration()
org.apache.rocketmq.client.apis.producer.Producer	producer(org.apache.rocketmq.client.apis.ClientServiceProvider provider, org.apache.rocketmq.client.apis.ClientConfiguration configuration)
RocketMqConsumer	rocketMqConsumer(org.apache.rocketmq.client.apis.ClientServiceProvider provider, org.apache.rocketmq.client.apis.ClientConfiguration configuration, org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer<Object> json, Sessions sessions, SessionGroups groups)
RocketMqProducer	rocketMqProducer(org.apache.rocketmq.client.apis.ClientServiceProvider provider, org.apache.rocketmq.client.apis.producer.Producer producer)
RocketMQPusher	rocketMQPusher(RocketMqProducer producer, org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer<Object> json)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

proxy

@Value(value="${rocketmq.proxy:127.0.0.1:8081}")
public String proxy

consumerGroup

@Value(value="${rocketmq.consumer.group:consumer-group}")
public String consumerGroup

topic

@Value(value="${rocketmq.topic:aim-topic}")
public String topic

accessKey

@Value(value="${rocketmq.accessKey:rocketmq2}")
public String accessKey

secretKey

@Value(value="${rocketmq.secretKey:12345678}")
public String secretKey

TAG_KILL

public static final String TAG_KILL

另请参阅:

常量字段值

构造器详细资料

RocketMQConfig

public RocketMQConfig()

方法详细资料

clientServiceProvider

@Bean
public org.apache.rocketmq.client.apis.ClientServiceProvider clientServiceProvider()

configuration

@Bean
public org.apache.rocketmq.client.apis.ClientConfiguration configuration()

producer

@Bean
public org.apache.rocketmq.client.apis.producer.Producer producer(org.apache.rocketmq.client.apis.ClientServiceProvider provider,
                                                                         org.apache.rocketmq.client.apis.ClientConfiguration configuration)
                                                                  throws org.apache.rocketmq.client.apis.ClientException

抛出:

org.apache.rocketmq.client.apis.ClientException

rocketMqProducer

@Bean
 @Primary
public RocketMqProducer rocketMqProducer(org.apache.rocketmq.client.apis.ClientServiceProvider provider,
                                                           org.apache.rocketmq.client.apis.producer.Producer producer)

rocketMqConsumer

@Bean
 @Primary
public RocketMqConsumer rocketMqConsumer(org.apache.rocketmq.client.apis.ClientServiceProvider provider,
                                                           org.apache.rocketmq.client.apis.ClientConfiguration configuration,
                                                           org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer<Object> json,
                                                           Sessions sessions,
                                                           SessionGroups groups)

rocketMQPusher

@Bean
public RocketMQPusher rocketMQPusher(RocketMqProducer producer,
                                            org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer<Object> json)