You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/01/12 17:43:06 UTC
[camel] branch master updated: Fixed Endpoint DSL RabbitMQ Test
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new a1c3323 Fixed Endpoint DSL RabbitMQ Test
a1c3323 is described below
commit a1c332361ccd5d007ac904d86b0b0cf63be31b4a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jan 12 18:40:04 2021 +0100
Fixed Endpoint DSL RabbitMQ Test
---
.../apache/camel/builder/endpoint/RabbitMQMultiValueTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/RabbitMQMultiValueTest.java b/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/RabbitMQMultiValueTest.java
index 746cbcd..80cffc3 100644
--- a/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/RabbitMQMultiValueTest.java
+++ b/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/RabbitMQMultiValueTest.java
@@ -22,7 +22,7 @@ import java.util.Map;
import org.apache.camel.ContextTestSupport;
import org.apache.camel.Endpoint;
import org.apache.camel.builder.endpoint.dsl.RabbitMQEndpointBuilderFactory;
-import org.apache.camel.component.rabbitmq.RabbitMQEndpoint;
+import org.apache.camel.component.springrabbit.RabbitMQEndpoint;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -42,14 +42,14 @@ public class RabbitMQMultiValueTest extends ContextTestSupport {
context.addRoutes(new EndpointRouteBuilder() {
@Override
public void configure() throws Exception {
- RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder builder = rabbitmq("mytopic").advanced()
+ RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder builder = springRabbitmq("mytopic").advanced()
.args("foo", "123")
.args("bar", "456")
.args("beer", "yes").basic();
Endpoint endpoint = builder.resolve(context);
assertNotNull(endpoint);
- assertEquals("rabbitmq://mytopic?arg.bar=456&arg.beer=yes&arg.foo=123", endpoint.getEndpointUri());
+ assertEquals("spring-rabbitmq://mytopic?arg.bar=456&arg.beer=yes&arg.foo=123", endpoint.getEndpointUri());
RabbitMQEndpoint re = assertIsInstanceOf(RabbitMQEndpoint.class, endpoint);
assertEquals("mytopic", re.getExchangeName());
Map<String, Object> args = re.getArgs();
@@ -76,12 +76,12 @@ public class RabbitMQMultiValueTest extends ContextTestSupport {
map.put("bar", "456");
map.put("beer", "yes");
- RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder builder = rabbitmq("mytopic").advanced()
+ RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder builder = springRabbitmq("mytopic").advanced()
.args(map).basic();
Endpoint endpoint = builder.resolve(context);
assertNotNull(endpoint);
- assertEquals("rabbitmq://mytopic?arg.bar=456&arg.beer=yes&arg.foo=123", endpoint.getEndpointUri());
+ assertEquals("spring-rabbitmq://mytopic?arg.bar=456&arg.beer=yes&arg.foo=123", endpoint.getEndpointUri());
RabbitMQEndpoint re = assertIsInstanceOf(RabbitMQEndpoint.class, endpoint);
assertEquals("mytopic", re.getExchangeName());
Map<String, Object> args = re.getArgs();