inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

ACS-5770 Restore activmq Camel support (#2159)

Browse Source
This commit is contained in:
Piotr Żurek
2023-08-25 12:19:18 +02:00
committed by GitHub
parent a7d49cb4c0
commit b884580688
2 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
repository/src/main/resources/alfresco/subsystems/Messaging/default/messaging-context.xml
View File

@@ -39,6 +39,10 @@
<property name="configuration" ref="jmsConfig"/> <property name="configuration" ref="jmsConfig"/>
</bean> </bean>
<bean id="activemq" class="org.apache.camel.component.activemq.ActiveMQComponent">
<property name="configuration" ref="jmsConfig"/>
</bean>
<bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent"> <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
<property name="configuration" ref="jmsConfig"/> <property name="configuration" ref="jmsConfig"/>
</bean> </bean>

17
repository/src/test/java/org/alfresco/messaging/camel/CamelComponentsTest.java
View File

@@ -48,12 +48,29 @@ public class CamelComponentsTest {
@Autowired @Autowired
protected CamelContext camelContext; protected CamelContext camelContext;
@Produce("activemq:queue:alfresco.test")
protected ProducerTemplate activemqTemplate;
@Produce("amqp:queue:alfresco.test") @Produce("amqp:queue:alfresco.test")
protected ProducerTemplate amqpTemplate; protected ProducerTemplate amqpTemplate;
@Produce("jms:queue:alfresco.test") @Produce("jms:queue:alfresco.test")
protected ProducerTemplate jmsTemplate; protected ProducerTemplate jmsTemplate;
@Test
public void testActivemqComponent()
{
final String msg = "ping <activemq>";
activemqTemplate.sendBody(msg);
final Object reply = camelContext
.createConsumerTemplate()
.receiveBody("activemq:queue:alfresco.test", 2000);
assertEquals(msg, reply);
}
@Test @Test
public void testAmqpComponent() public void testAmqpComponent()
{ {