Package org.springframework.integration.redis.inbound

Examples of org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint


    outputChannel.setBeanFactory(BusTestUtils.MOCK_BF);
    outputChannel.subscribe(new TestMessageHandler());

    this.currentQueueName = QUEUE_NAME + ":" + System.nanoTime();

    adapter = new RedisQueueMessageDrivenEndpoint(currentQueueName, connectionFactory);
    adapter.setBeanFactory(BusTestUtils.MOCK_BF);
    adapter.setOutputChannel(outputChannel);
  }
View Full Code Here


  private MessageProducerSupport createInboundAdapter(RedisPropertiesAccessor accessor, String queueName) {
    MessageProducerSupport adapter;
    int concurrency = accessor.getConcurrency(this.defaultConcurrency);
    concurrency = concurrency > 0 ? concurrency : 1;
    if (concurrency == 1) {
      RedisQueueMessageDrivenEndpoint single = new RedisQueueMessageDrivenEndpoint(queueName,
          this.connectionFactory);
      single.setBeanFactory(getBeanFactory());
      single.setSerializer(null);
      adapter = single;
    }
    else {
      adapter = new CompositeRedisQueueMessageDrivenEndpoint(queueName, concurrency);
    }
View Full Code Here

    private final List<RedisQueueMessageDrivenEndpoint> consumers = new ArrayList<RedisQueueMessageDrivenEndpoint>();

    public CompositeRedisQueueMessageDrivenEndpoint(String queueName, int concurrency) {
      for (int i = 0; i < concurrency; i++) {
        RedisQueueMessageDrivenEndpoint adapter = new RedisQueueMessageDrivenEndpoint(queueName,
            connectionFactory);
        adapter.setBeanFactory(RedisMessageBus.this.getBeanFactory());
        adapter.setSerializer(null);
        adapter.setBeanName("inbound." + queueName + "." + i);
        this.consumers.add(adapter);
      }
      this.setBeanFactory(RedisMessageBus.this.getBeanFactory());
    }
View Full Code Here

TOP

Related Classes of org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.