Examples of org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Package org.springframework.amqp.rabbit.connection

Examples of org.springframework.amqp.rabbit.connection.CachingConnectionFactory

org.springframework.amqp.rabbit.connection.CachingConnectionFactory
A {@link ConnectionFactory} implementation that (when the cache mode is {@link CacheMode#CHANNEL} (default)returns the same Connection from all {@link #createConnection()}calls, and ignores calls to {@link com.rabbitmq.client.Connection#close()} and caches{@link com.rabbitmq.client.Channel}.
By default, only one Channel will be cached, with further requested Channels being created and disposed on demand. Consider raising the {@link #setChannelCacheSize(int) "channelCacheSize" value} in case of a high-concurrencyenvironment.
When the cache mode is {@link CacheMode#CONNECTION}, a new (or cached) connection is used for each request. In this case, no channels are cached, just connections. The intended use case is a dedicated connection for long-lived channels, such as those used in listener container threads. In those cases, the channel must be closed anyway in order to re-queue any un-acked messages.
{@link CacheMode#CONNECTION} is not compatible with a Rabbit Admin that auto-declares queues etc.
NOTE: This ConnectionFactory requires explicit closing of all Channels obtained form its shared Connection. This is the usual recommendation for native Rabbit access code anyway. However, with this ConnectionFactory, its use is mandatory in order to actually allow for Channel reuse. @author Mark Pollack @author Mark Fisher @author Dave Syer @author Gary Russell @author Artem Bilan

      @Override
      public Object answer(InvocationOnMock invocation) throws Throwable {
        return count.incrementAndGet();
      }}).when(mockChannel).getNextPublishSeqNo();


    CachingConnectionFactory ccf = new CachingConnectionFactory(mockConnectionFactory);
    ccf.setPublisherConfirms(true);
    final RabbitTemplate template = new RabbitTemplate(ccf);


    final CountDownLatch latch = new CountDownLatch(2);
    template.setConfirmCallback(new ConfirmCallback() {

View Full Code Here

      public Object answer(InvocationOnMock invocation) throws Throwable {
        return count.incrementAndGet();
      }
    }).when(mockChannel).getNextPublishSeqNo();


    CachingConnectionFactory ccf = new CachingConnectionFactory(mockConnectionFactory);
    ccf.setPublisherConfirms(true);
    final RabbitTemplate template1 = new RabbitTemplate(ccf);


    final Set<String> confirms = new HashSet<String>();
    final CountDownLatch latch1 = new CountDownLatch(1);
    template1.setConfirmCallback(new ConfirmCallback() {

View Full Code Here

    when(mockConnectionFactory.newConnection((ExecutorService) null)).thenReturn(mockConnection);
    when(mockConnection.isOpen()).thenReturn(true);
    final PublisherCallbackChannelImpl channel = new PublisherCallbackChannelImpl(mockChannel);
    when(mockConnection.createChannel()).thenReturn(channel);


    CachingConnectionFactory ccf = new CachingConnectionFactory(mockConnectionFactory);
    ccf.setPublisherConfirms(true);
    ccf.setChannelCacheSize(3);
    final RabbitTemplate template = new RabbitTemplate(ccf);


    final CountDownLatch first2SentOnThread1Latch = new CountDownLatch(1);
    final CountDownLatch delayAckProcessingLatch = new CountDownLatch(1);
    final CountDownLatch startedProcessingMultiAcksLatch = new CountDownLatch(1);

View Full Code Here


  @Override
  public void append(LoggingEvent event) {
    if (null == senderPool && this.initializing.compareAndSet(false, true)) {
      try {
        connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(virtualHost);

View Full Code Here

    super.start();
    this.routingKeyLayout.setContext(getContext());
    this.routingKeyLayout.start();
    this.locationLayout.setContext(getContext());
    this.locationLayout.start();
    this.connectionFactory = new CachingConnectionFactory();
    this.connectionFactory.setHost(this.host);
    this.connectionFactory.setPort(this.port);
    this.connectionFactory.setUsername(this.username);
    this.connectionFactory.setPassword(this.password);
    this.connectionFactory.setVirtualHost(this.virtualHost);

View Full Code Here

  @Test
  public void testArgumentsQueue() throws Exception {


    Queue queue = beanFactory.getBean("arguments", Queue.class);
    assertNotNull(queue);
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory(BrokerTestUtils.getPort());
    connectionFactory.setHost("localhost");
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    RabbitAdmin rabbitAdmin = new RabbitAdmin(template.getConnectionFactory());
    rabbitAdmin.deleteQueue(queue.getName());
    rabbitAdmin.declareQueue(queue);


    assertEquals(100L, queue.getArguments().get("x-message-ttl"));
    template.convertAndSend(queue.getName(), "message");


    Thread.sleep(200);
    String result = (String) template.receiveAndConvert(queue.getName());
    assertEquals(null, result);


    connectionFactory.destroy();


  }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.springframework.amqp.rabbit.connection.CachingConnectionFactory

amqp.spring.camel.component.SpringAMQPComponent

amqp.spring.camel.component.SpringAMQPComponentTest

amqp.spring.camel.component.SpringAMQPConsumerTest

amqp.spring.camel.component.SpringAMQPEndpointTest

amqp.spring.camel.component.SpringAMQPProducerTest

com.emc.plants.messaging.config.RabbitClientConfiguration

com.heroku.devcenter.RabbitConfiguration

com.jbrisbin.groovy.mqdsl.RabbitMQDsl

com.kurento.kmf.rabbitmq.RabbitMqManager

com.rabbitmq.client.Channel

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.