You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/04/17 09:41:32 UTC
[camel] 15/38: CAMEL-13421: Remove BeanInvocation from camel-bean
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch mock
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2b34c484c65691b02e16e530e745383bcf66f069
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Apr 16 10:32:58 2019 +0200
CAMEL-13421: Remove BeanInvocation from camel-bean
---
.../component/jms/remoting/CalculatorImpl.java | 25 --------
.../component/jms/remoting/JmsProxyMEPTest.java | 67 ---------------------
.../camel/component/jms/remoting/JmsProxyTest.java | 68 ----------------------
3 files changed, 160 deletions(-)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/CalculatorImpl.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/CalculatorImpl.java
deleted file mode 100644
index 933c371..0000000
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/CalculatorImpl.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jms.remoting;
-
-public class CalculatorImpl implements Calculator {
-
- @Override
- public int add(int op1, int op2) {
- return op1 + op2;
- }
-}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyMEPTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyMEPTest.java
deleted file mode 100644
index 6e9b159..0000000
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyMEPTest.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jms.remoting;
-
-import javax.jms.ConnectionFactory;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.builder.ProxyBuilder;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.jms.CamelJmsTestHelper;
-import org.apache.camel.test.junit4.CamelTestSupport;
-import org.junit.Test;
-
-import static org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknowledge;
-
-public class JmsProxyMEPTest extends CamelTestSupport {
-
- protected String componentName = "activemq";
- private Calculator calculatorProxy;
-
- protected CamelContext createCamelContext() throws Exception {
- CamelContext camelContext = super.createCamelContext();
-
- ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
- camelContext.addComponent(componentName, jmsComponentAutoAcknowledge(connectionFactory));
-
- // create proxy
- calculatorProxy = new ProxyBuilder(camelContext).binding(false).endpoint("direct:calculatorProxy").build(Calculator.class);
-
- return camelContext;
- }
-
- @Test
- public void testSynchronous() throws Exception {
- int result = calculatorProxy.add(30, 13);
- assertEquals(43, result);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from("direct:calculatorProxy")
- .to("log:calc")
- .to("activemq:calculator-queue?exchangePattern=InOut");
-
- from("activemq:calculator-queue?exchangePattern=InOut").bean(CalculatorImpl.class);
- }
- };
- }
-
-}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyTest.java
deleted file mode 100644
index 57eaca9..0000000
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/remoting/JmsProxyTest.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jms.remoting;
-
-import javax.jms.ConnectionFactory;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.builder.ProxyBuilder;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.jms.CamelJmsTestHelper;
-import org.apache.camel.test.junit4.CamelTestSupport;
-import org.junit.Test;
-
-import static org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknowledge;
-
-public class JmsProxyTest extends CamelTestSupport {
-
- protected String componentName = "activemq";
- private Calculator calculatorProxy;
-
- protected CamelContext createCamelContext() throws Exception {
- CamelContext camelContext = super.createCamelContext();
-
- ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
- camelContext.addComponent(componentName, jmsComponentAutoAcknowledge(connectionFactory));
-
- // create proxy
- calculatorProxy = new ProxyBuilder(camelContext).binding(false).endpoint("direct:calculatorProxy").build(Calculator.class);
-
- return camelContext;
- }
-
- @Test
- public void testSynchronous() throws Exception {
- int result = calculatorProxy.add(30, 12);
- assertEquals(42, result);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from("direct:calculatorProxy")
- .to("log:calc")
- .to("activemq:calculator-queue");
-
- from("activemq:calculator-queue").bean(CalculatorImpl.class);
-
- }
- };
- }
-
-}