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 <claus.ib...@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); - - } - }; - } - -}