本文整理了Java中org.springframework.data.redis.listener.RedisMessageListenerContainer.start
方法的一些代码示例,展示了RedisMessageListenerContainer.start
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisMessageListenerContainer.start
方法的具体详情如下:
包路径:org.springframework.data.redis.listener.RedisMessageListenerContainer
类名称:RedisMessageListenerContainer
方法名:start
暂无
代码示例来源:origin: spring-projects/spring-data-redis
private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
// stop the listener if currently running
if (isRunning()) {
subscriptionTask.cancel();
}
patternMapping.clear();
channelMapping.clear();
listenerTopics.clear();
if (!CollectionUtils.isEmpty(listeners)) {
for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
addListener(entry.getKey(), entry.getValue());
}
}
// resume activity
if (initialized) {
start();
}
}
代码示例来源:origin: spring-projects/spring-data-redis
private void initMessageListenerContainer() {
this.messageListenerContainer = new RedisMessageListenerContainer();
this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
this.messageListenerContainer.afterPropertiesSet();
this.messageListenerContainer.start();
}
代码示例来源:origin: spring-projects/spring-integration
@Override
public void start() {
this.container.start();
}
代码示例来源:origin: spring-projects/spring-integration
@Override
protected void doStart() {
super.doStart();
this.container.start();
}
代码示例来源:origin: com.github.xiaolyuh/layering-cache-core
@Override
public void start() {
container.start();
}
代码示例来源:origin: xiaolyuh/layering-cache
@Override
public void start() {
container.start();
}
代码示例来源:origin: org.springframework.integration/spring-integration-redis
@Override
public void start() {
this.container.start();
}
代码示例来源:origin: org.springframework.integration/spring-integration-redis
@Override
protected void doStart() {
super.doStart();
this.container.start();
}
代码示例来源:origin: sentilo/sentilo
private void restartListenerContainer() {
LOGGER.info("Stopping listener container for process {}", processName);
try {
listenerContainer.stop();
} catch (final Exception re) {
LOGGER.warn("An error occurred while stopping listener container. If it is not running, we proceed to start it", re.getMessage());
}
// Clear count pending events value
countPendingEvents = 0;
LOGGER.info("Starting listener container");
if (!listenerContainer.isRunning()) {
listenerContainer.start();
}
}
代码示例来源:origin: spring-projects/spring-integration
@Test
@RedisAvailable
public void testRedisPublishingMessageHandler() throws Exception {
int numToTest = 10;
String topic = "si.test.channel";
final CountDownLatch latch = new CountDownLatch(numToTest * 2);
RedisConnectionFactory connectionFactory = this.getConnectionFactoryForTest();
MessageListenerAdapter listener = new MessageListenerAdapter();
listener.setDelegate(new Listener(latch));
listener.setSerializer(new StringRedisSerializer());
listener.afterPropertiesSet();
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.afterPropertiesSet();
container.addMessageListener(listener, Collections.<Topic>singletonList(new ChannelTopic(topic)));
container.start();
this.awaitContainerSubscribed(container);
final RedisPublishingMessageHandler handler = new RedisPublishingMessageHandler(connectionFactory);
handler.setTopicExpression(new LiteralExpression(topic));
for (int i = 0; i < numToTest; i++) {
handler.handleMessage(MessageBuilder.withPayload("test-" + i).build());
}
for (int i = 0; i < numToTest; i++) {
handler.handleMessage(MessageBuilder.withPayload(("test-" + i).getBytes()).build());
}
assertTrue(latch.await(10, TimeUnit.SECONDS));
container.stop();
}
代码示例来源:origin: org.springframework.data/spring-data-redis
private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
// stop the listener if currently running
if (isRunning()) {
subscriptionTask.cancel();
}
patternMapping.clear();
channelMapping.clear();
listenerTopics.clear();
if (!CollectionUtils.isEmpty(listeners)) {
for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
addListener(entry.getKey(), entry.getValue());
}
}
// resume activity
if (initialized) {
start();
}
}
代码示例来源:origin: apache/servicemix-bundles
private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
// stop the listener if currently running
if (isRunning()) {
subscriptionTask.cancel();
}
patternMapping.clear();
channelMapping.clear();
listenerTopics.clear();
if (!CollectionUtils.isEmpty(listeners)) {
for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
addListener(entry.getKey(), entry.getValue());
}
}
// resume activity
if (initialized) {
start();
}
}
代码示例来源:origin: apache/servicemix-bundles
private void initMessageListenerContainer() {
this.messageListenerContainer = new RedisMessageListenerContainer();
this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
this.messageListenerContainer.afterPropertiesSet();
this.messageListenerContainer.start();
}
代码示例来源:origin: org.springframework.data/spring-data-redis
private void initMessageListenerContainer() {
this.messageListenerContainer = new RedisMessageListenerContainer();
this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
this.messageListenerContainer.afterPropertiesSet();
this.messageListenerContainer.start();
}
内容来源于网络,如有侵权,请联系作者删除!