This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" init-method="start" destroy-method="stop"> | |
<property name="maxConnections" value="10" /> | |
<property name="maximumActiveSessionPerConnection" value="10" /> | |
<property name="connectionFactory" > | |
<bean class="org.apache.activemq.ActiveMQConnectionFactory"> | |
<property name="brokerURL" value="tcp://127.0.0.1:61616" /> | |
</bean> | |
</property> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration"> | |
<property name="connectionFactory" ref="pooledConnectionFactory" /> | |
<property name="transacted" value="true" /> | |
<property name="concurrentConsumers" value="15" /> | |
<property name="deliveryPersistent" value="true" /> | |
<property name="requestTimeout" value="10000" /> | |
<property name="cacheLevelName" value="CACHE_CONSUMER" /> | |
</bean> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from("activemq:test.queue") | |
.routeId("test.queue.routeId") | |
.to("log:org.apache.camel.blog?groupSize=100"); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[INFO] ------------------------------------------------------------------------ | |
[INFO] BUILD FAILURE | |
[INFO] ------------------------------------------------------------------------ | |
[INFO] Total time: 2.234s | |
[INFO] Finished at: Mon May 19 08:42:46 MST 2014 | |
[INFO] Final Memory: 34M/310M | |
[INFO] ------------------------------------------------------------------------ | |
[ERROR] Failed to execute goal org.kie:kie-maven-plugin:6.0.2-redhat-6:build (default-build) on project HelloWorld: Execution default-build of goal org.kie:kie-maven-plugin:6.0.2-redhat-6:build failed: Unable to instantiate service for Class 'org.drools.compiler.compiler.BPMN2ProcessProvider': Unable to instantiate 'org.jbpm.bpmn2.BPMN2ProcessProviderImpl' -> [Help 1] | |
[ERROR] | |
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[INFO] 27 errors | |
[INFO] ------------------------------------------------------------- | |
[INFO] ------------------------------------------------------------------------ | |
[INFO] BUILD FAILURE | |
[INFO] ------------------------------------------------------------------------ | |
[INFO] Total time: 1.516s | |
[INFO] Finished at: Wed Jun 11 16:37:00 MST 2014 | |
[INFO] Final Memory: 17M/310M | |
[INFO] ------------------------------------------------------------------------ | |
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:2.5.1:compile (default-compile) on project eval-jms: Compilation failure: Compilation failure: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.redhat.poc.mediacom.asyncjmsexample; | |
public interface RestService { | |
public String getBackendService(IncomingRequest request); | |
} | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
146 /** | |
147 * Eventually add the security subject that has created this event. | |
148 */ | |
149 private void prepare(final Event event) | |
150 { | |
151 Subject subject = Subject.getSubject(AccessController.getContext()); | |
152 if (subject != null) | |
153 { | |
154 try | |
155 { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
12:12:24,091 INFO [org.switchyard.handlers.MessageTraceHandler] (Camel (camel-27) thread #35 - JmsConsumer[test.queue]) | |
------- Begin Message Trace ------- | |
Consumer -> {urn:com.redhat.poc:jms-switchyard-example:1.0}AsyncService | |
Provider -> {urn:com.redhat.poc:jms-switchyard-example:1.0}AsyncService | |
Operation -> newMessage | |
MEP -> IN_ONLY | |
Phase -> OUT | |
State -> FAULT | |
Exchange Context -> | |
CamelCreatedTimestamp ............................: Tue Jun 24 12:12:24 MST 2014 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<sy:switchyard xmlns:camel="urn:switchyard-component-camel:config:1.1" xmlns:jms="urn:switchyard-component-camel-jms:config:1.1" xmlns:resteasy="urn:switchyard-component-resteasy:config:1.1" xmlns:sca="http://docs.oasis-open.org/ns/opencsa/sca/200912" xmlns:soap="urn:switchyard-component-soap:config:1.1" xmlns:sy="urn:switchyard-config:switchyard:1.1" name="jms-switchyard-example" targetNamespace="urn:com.redhat.poc:jms-switchyard-example:1.0"> | |
<sca:composite name="jms-switchyard-example" targetNamespace="urn:com.redhat.poc:jms-switchyard-example:1.0"> | |
<sca:component name="CamelServiceRoute"> | |
<camel:implementation.camel> | |
<camel:java class="com.redhat.poc.jms_switchyard_example.CamelServiceRoute"/> | |
</camel:implementation.camel> | |
<sca:service name="AsyncService"> | |
<sca:interface.java interface="com.redhat.poc.jms_switchyard_example.AsyncService"/> | |
</sca:service> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Path("/") | |
public class IncomingRestResource { | |
@POST | |
public String getBackendService(IncomingRequest request) { | |
return null; | |
} | |
} |
OlderNewer