Package org.springframework.amqp.core

Examples of org.springframework.amqp.core.DirectExchange

423
424
425
426
427
428
429
430
431
432
433
      Exchange x;
      if ("topic".equals(exchangeType)) {
        x = new TopicExchange(exchangeName, durable, autoDelete);
      }
      else if ("direct".equals(exchangeType)) {
        x = new DirectExchange(exchangeName, durable, autoDelete);
      }
      else if ("fanout".equals(exchangeType)) {
        x = new FanoutExchange(exchangeName, durable, autoDelete);
      }
      else if ("headers".equals(exchangeType)) {
View Full Code Here
422
423
424
425
426
427
428
429
430
431
432
      Exchange x;
      if ("topic".equals(this.exchangeType)) {
        x = new TopicExchange(this.exchangeName, this.durable, this.autoDelete);
      }
      else if ("direct".equals(this.exchangeType)) {
        x = new DirectExchange(this.exchangeName, this.durable, this.autoDelete);
      }
      else if ("fanout".equals(this.exchangeType)) {
        x = new FanoutExchange(this.exchangeName, this.durable, this.autoDelete);
      }
      else if ("headers".equals(this.exchangeType)) {
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
    reader.loadBeanDefinitions(new ClassPathResource(getClass().getSimpleName() + "-context.xml", getClass()));
  }

  @Test
  public void testDirectExchange() throws Exception {
    DirectExchange exchange = beanFactory.getBean("direct", DirectExchange.class);
    assertNotNull(exchange);
    assertEquals("direct", exchange.getName());
    assertTrue(exchange.isDurable());
    assertFalse(exchange.isAutoDelete());
    assertFalse(exchange.shouldDeclare());
    assertEquals(2, exchange.getDeclaringAdmins().size());
    Binding binding = beanFactory.getBean("org.springframework.amqp.rabbit.config.BindingFactoryBean#0", Binding.class);
    assertFalse(binding.shouldDeclare());
    assertEquals(2, binding.getDeclaringAdmins().size());

    Map<String, Object> arguments = binding.getArguments();
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
  }

  @Test
  public void testAliasDirectExchange() throws Exception {
    DirectExchange exchange = beanFactory.getBean("alias", DirectExchange.class);
    assertNotNull(exchange);
    assertEquals("direct-alias", exchange.getName());
    assertTrue(exchange.isDurable());
    assertFalse(exchange.isAutoDelete());
  }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
  }

  @Test
  public void testDirectExchangeOverride() throws Exception {
    DirectExchange exchange = beanFactory.getBean("direct-override", DirectExchange.class);
    assertNotNull(exchange);
    assertEquals("direct-override", exchange.getName());
    assertFalse(exchange.isDurable());
    assertTrue(exchange.isAutoDelete());
  }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
    assertTrue(exchange.isAutoDelete());
  }

  @Test
  public void testDirectExchangeWithArguments() throws Exception {
    DirectExchange exchange = beanFactory.getBean("direct-arguments", DirectExchange.class);
    assertNotNull(exchange);
    assertEquals("direct-arguments", exchange.getName());
    assertEquals("bar", exchange.getArguments().get("foo"));
  }
View Full Code Here
138
139
140
141
142
143
144
145
146
147
    assertEquals("bar", exchange.getArguments().get("foo"));
  }

  @Test
  public void testDirectExchangeWithReferencedArguments() throws Exception {
    DirectExchange exchange = beanFactory.getBean("direct-ref-arguments", DirectExchange.class);
    assertNotNull(exchange);
    assertEquals("direct-ref-arguments", exchange.getName());
    assertEquals("bar", exchange.getArguments().get("foo"));
  }
View Full Code Here
TOP

Related Classes of org.springframework.amqp.core.DirectExchange

  • amqp.spring.camel.component.SpringAMQPEndpoint
  • com.jbrisbin.groovy.mqdsl.RabbitMQBuilder
  • com.kurento.kmf.rabbitmq.RabbitMqManager
  • org.cloudfoundry.picalc.config.AbstractConfiguration
  • org.jamescarr.amqp.example.CommonConfiguration
  • org.springframework.amqp.rabbit.config.ExchangeParserTests
  • org.springframework.amqp.rabbit.core.FixedReplyQueueDeadLetterTests$FixedReplyQueueDeadLetterConfig
  • org.springframework.amqp.rabbit.core.RabbitAdminDeclarationTests
  • org.springframework.amqp.rabbit.core.RabbitAdminDeclarationTests$Config
  • org.springframework.amqp.rabbit.core.RabbitAdminIntegrationTests
    • 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.