topic Activiti-camel defect? in Alfresco Archive https://connect.hyland.com/t5/alfresco-archive/activiti-camel-defect/m-p/74942#M49183 <HTML><HEAD></HEAD><BODY><SPAN>Hi,</SPAN><BR /><SPAN>I am using the activiti-camel integration (after reading the latest installment of "Activiti in Action"). Nice jobs all around! Kudos!</SPAN><BR /><SPAN>My problem comes with my unit test. My routes look like:</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; from("activiti:myProcess:servicetask1")<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .log(LoggingLevel.INFO, "Received message on service task")<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .to("jms:queue:myQueue");<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; from("direct:start")<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .to("activiti:myProcess");<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><SPAN>Which I want to unit test using a MockEndpoint. I checked out </SPAN><A href="http://camel.apache.org/mock.html" rel="nofollow noopener noreferrer">http://camel.apache.org/mock.html</A><SPAN>, especially the section on "Mocking Existing Endpoints" and so I coded my unit test as:</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&nbsp;&nbsp;&nbsp; @Autowired<BR />&nbsp;&nbsp;&nbsp; private CamelContext camelContext;<BR /><BR />&nbsp;&nbsp;&nbsp; @Produce(uri = "direct:start", context = "camelProcess")<BR />&nbsp;&nbsp;&nbsp; protected ProducerTemplate template;<BR /><BR />&nbsp;&nbsp;&nbsp; @Test<BR />&nbsp;&nbsp;&nbsp; public void testMyProcessViaCamel() throws Exception {<BR /><BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Advise all the endpoints<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (final RouteDefinition route : this.camelContext.getRouteDefinitions()) {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; route.adviceWith(this.camelContext, new AdviceWithRouteBuilder() {<BR /><BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void configure() throws Exception {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // mock all endpoints<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.mockEndpoints();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; });<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><SPAN>But this fails because I get a RuntimeException from the ActivitiEndpoint class:</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&nbsp; void addConsumer(ActivitiConsumer consumer) {<BR />&nbsp;&nbsp;&nbsp; if (activitiConsumer != null) {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new RuntimeException("Activit consumer already defined for " + getEndpointUri() + "!");<BR />&nbsp;&nbsp;&nbsp; }<BR />&nbsp;&nbsp;&nbsp; activitiConsumer = consumer;<BR />&nbsp; }<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><SPAN>I was wondering if the ActivitiEndpoint should even care about adding a consumer when one has already been added? In this case, Camel has it's reasons for replacing the existing consumer.</SPAN><BR /><SPAN>Is there a reason for addConsumer not being as follows?</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&nbsp; void addConsumer(ActivitiConsumer consumer) {<BR />&nbsp;&nbsp;&nbsp; activitiConsumer = consumer;<BR />&nbsp; }<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><BR /><SPAN>Thanks for reading this to the end!</SPAN><BR /><BR /><SPAN>Nick.</SPAN></BODY></HTML> Thu, 22 Sep 2011 20:31:03 GMT njames 2011-09-22T20:31:03Z Activiti-camel defect? https://connect.hyland.com/t5/alfresco-archive/activiti-camel-defect/m-p/74942#M49183 Hi,I am using the activiti-camel integration (after reading the latest installment of "Activiti in Action"). Nice jobs all around! Kudos!My problem comes with my unit test. My routes look like:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; from("activiti:myProcess:servicetask1")&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .log(LoggingLevel.INFO, "Received message on ser Thu, 22 Sep 2011 20:31:03 GMT https://connect.hyland.com/t5/alfresco-archive/activiti-camel-defect/m-p/74942#M49183 njames 2011-09-22T20:31:03Z Re: Activiti-camel defect? https://connect.hyland.com/t5/alfresco-archive/activiti-camel-defect/m-p/74943#M49184 <HTML><HEAD></HEAD><BODY><SPAN>Hi,</SPAN><BR /><BR /><SPAN>Hmm good question. Can you share your test project so I can try to reproduce this?</SPAN><BR /><BR /><SPAN>Best regards,</SPAN></BODY></HTML> Fri, 23 Sep 2011 11:20:09 GMT https://connect.hyland.com/t5/alfresco-archive/activiti-camel-defect/m-p/74943#M49184 trademak 2011-09-23T11:20:09Z