HTTP Proxy with File Attachments

Hi all, I am running into an issue when doing something I feel should probably be very simple. In a servicemix bundle, I need it to act is a proxy to another http endpoint on another server. This all works without issues until an attachment is sent along with the http request. Here is all my

Re: HTTP Proxy with File Attachments

By enable logs do you mean set them to debug in servicemix? I am using Redhat Fuse ESB 6.1. I can try to log out each complete request, should actually be able to enable that stuff on the service layer as well. Might see a difference. I was still hoping there was just a config option I was

camel-activiti configuration

Greetings, I am having a bit of an issue and I think it may be solved potentially by defining something currently available in blueprint config, to spring config. I am integrating activiti and camel using the camel-activiti bundle, and currently through my spring config I have hit a bit of a

Question Around Spring Context and Activiti Tasks

Hello everyone, I am working on integrating a camel route with an activiti process (using activiti-camel engine). My question is, I have spring beans defined in a camel-beans.xml such as Activiti uses some POJOs for task delegation and I want to be

Camel Activiti

Hello. I am currently beginning a project to integrate our existing ServiceMix and Camel ESB with Activiti. I have looked into this a bit and I am a little confused. With Camel's activiti integration, how would it be possible for me to leverage something like activiti explorer to manage the

Re: Port already in use when using CXF consumer and jetty

I ended up writing an internal router to solve this. You can setup a jetty listener on the port you want and read the URL to determine which internal port to route the message to. So internally I use ports 9191 - 9196 for various services and just send requests internally to those after

Re: Unit Testing Question

I figured it out, was an sl4j version issue. Seems things are working now so I appreciate the help! -- View this message in context: http://camel.465427.n5.nabble.com/Unit-Testing-Question-tp5745966p5746502.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Unit Testing Question

Still have not been able to figure this out. I tried few simple purely JUnit tests and they worked fine and were executed by surefire with no issues, but for some reason once I extend to CamelTestSupport it says no tests were found no matter what kind of tests are there. Could this be a version

Re: Unit Testing Question

I changed my import of org.apache.camel.test.CamelTestSupport to org.apache.camel.test.junit4.CamelTestSupport, and now it generates a different error within surefire. Tests in error: SimpleTestTestSupport.clinit:55 » NoClassDefFound org/s... SimpleTest.com.ihg.atp.ess.processor.SimpleTest »

Re: Unit Testing Question

For the fixtures in the example, does that need to be embedded into a Routebuilder? I'm still trying to setup this simple example but unsure how the fixture here is actually invoked. Currently all of my routes are actually created in the spring DSL as well. Any elaboration on this would be

Re: Unit Testing Question

I've been reading over all of the test documentation and Mock documentation. It seems that I should be able to just setup a mock endpoint for the URI of the processor and use the producer template to send the information to the endpoint and run the asserts on that endpoint. Is that a proper

Re: Unit Testing Question

In most cases in my code I utilize processors to do exactly what you mention. This situation is sort of a special case where I wanted to house all of the route logic within a single class in the java DSL. Typically in this project I have setup to use camel-jdbc, camel-cxf, etc as their own

Re: Unit Testing Question

So to go a bit further, assuming I setup the producer template to mimic and exchange to test this method, how then do I send that exchange to the method? Do I just instantiate the processor within the test case and use the template.send(Processor) method signature to do this? If so how then do I

Unit Testing Question

Greetings, I have a question around unit testing within Camel as I am fairly new to it. I have a process: public void setProcessStatus(Exchange exchange) throws Exception { String processName = exchange.getIn().getHeader(process_name, String.class); String

Premature end of file on return from HTTP endpoint

I am submitting messages to an HTTP web service through camel. For some reason, when I am attempting to call an xpath expression on the result I am getting a org.xml.sax.SAXParseException: Premature end of file. Looking at the body of the SOAP XML that is being returned by the HTTP endpoint, I

Custom Bean for use with a Splitter

I have created a custom bean that takes in some data as the body of a message, and converts it to a java List. I am using the spring DSL for my routes and don't know how I can convert the following to the spring version: from(direct:body) .split().method(mySplitterBean, splitBody)

Port already in use when using CXF consumer and jetty

I am getting the following error when deploying a bundle which contains a CXF consumer for a web service as well as a simple jetty endpoint. org.apache.camel.RuntimeCamelException: org.apache.cxf.interceptor.Fault: Could not start Jetty server on port 9,191: Address already in use Here is what

Re: HOW-TO: Jetty, JSON, and Restful Services

Just a note, you can remove more than one header at once with removeHeaders pattern=Camel*/ or even removeHeaders pattern=*/ Using wildcards and such. I don't think the headers that are populated off of the jetty endpoint are going to be causing the issue. If you are just trying to pass

Re: Sift Appender Logging

Was hoping someone had some experience in relation to karaf and using the pax sift appender with rolling logs, didn't think it was unreasonable. I'll take it up with the PAX team or another resource. -- View this message in context:

Sift Appender Logging

Greetings, I have edited my /etc/org.ops4j.pax.logging.cfg file to the following, to allow each bundle to create a separate log file. Unfortunately, the max file size and log indexing seems to not work when using the sift appender. I will attach the config file, but currently all the logs only

Re: SSL and CXF Consumers

I am trying to setup the conduit and jetty engine much like in the SVN example. For some reason I am getting an error: 13:31:50,019 | ERROR | xtenderThread-11 | ContextLoaderListener| ? ? | 84 - org.springframework.osgi.extender - 1.2.1 | Application

Re: SSL and CXF Consumers

Basically all I am really trying to do is take incoming CXF requests over https, then route it to the webservice on another server using https. Being new to this sort of thing I have a few questions that might help me find the direction: Do I need to deploy the SSL cert to the bundle/route

Re: SSL and CXF Consumers

Thanks for the reply, I will work through some of the configuration shortly. I did however notice that when I changed my cxf consumer to use an address of https, that my route would no longer deploy saying that SSL protocol could not be used on an http configured endpoint. Looking deeper it

Re: SSL and CXF Consumers

Hmm let me try to rephrase a bit. How would you go about securing a CXF consumer endpoint with an SSL cert that is open to the outside world? Do you need to route it through an http conduit or is there some way to have the SSL cert live on the CXF endpoint itself? -- View this message in

SSL and CXF Consumers

I can find a pretty good amount of documentation and examples around setting up and http endpoint to use an SSL cert and receive messages on https, but what I am trying to do is have a CXF consumer perform the same way. Is there a way to deploy an SSL cert for a CXF consumer, and if not how would

Re: Trapping Errors Help

That's a nice little trick with the onWhen, I like it. Where does that fall in the scope of the exception block? Would it just run something like the following? After the onWhen runs does the flow pass through the to the statements afterwards, or is there some sort of else clause I need to use

Trapping Errors Help

I am trying to trap errors thrown in camel and am running into a bit of an issue with nested errors. For example: org.apache.cxf.binding.soap.SoapFault: Error reading XMLStreamReader. at

Re: Detecting SOAP Faults

Ah that makes sense, thank you. So basically I can just setup onException blocks to look for something like org.apache.cxf.interceptor.Fault to indicate a SOAP Fault, then within that onException block I could use a processor to do what I need? Something like this in the processor? SoapFault

Re: Detecting SOAP Faults

I have done a bit more testing with this and seem to not be able to actually catch SOAP faults as exceptions. Lets say my CXF consumer throws the following in my route: 13:58:57,419 | WARN | qtp50072751-7150 | PhaseInterceptorChain| ? ? | - - |

Re: Detecting SOAP Faults

I actually do have validation enabled on the CXF consumer in the properties with the schema-validation-enabled which I guess is why it returns a SOAP fault to the calling client and not something else. I didn't realize a CXF consumer never technically enters a route unless the consumer parse is

Detecting SOAP Faults

I currently have a custom processor setup within a route that does the following public class SoapFaultDetectionProcessor implements Processor { public void process(Exchange exchange) throws Exception { if(exchange.getIn().isFault()) { SoapFault

CXF and Overriding SOAP Faults

Greetings, I was wondering if it was possible to overwrite a SOAP fault generated by a CXF consumer. Currently I have a route setup that starts from a CXF consumer and then sends to a CXF producer. I have schema validation turned on in the consumer, so it seems that when an invalid message

Re: CXF and Overriding SOAP Faults

The reason I need the ability to modify the SOAP faults is because the SOAP fault messages will be directly viewed by a user from a client with an external app, so rather than display something potentially cryptic we are going to spend some time wrapping the errors in custom error codes with human

Re: CXF Question

Just to help understanding, here is basically what I am doing, catching an incoming request on a jetty port, log the message, route to cxf component, log the response. How do I leverage the cxf endpoint to validate? Like I said currently it is in MESSAGE dataformat so that is not happening, but

Re: CXF Question

I guess really the question is how do you go about using the jaxb component to properly do this? Or is there an example somewhere that shows this within spring to marshal and incoming message and send it to a POJO cxf endpoint? -- View this message in context:

Re: CXF Question

I have it working in MESSAGE format already, but I wanted the cxf endpoint to do some validating on data types and message format before ever sending it to the actual cxf address (another server) What is the best way to do this? I have a webservice with a WSDL deployed as a camel cxf component

CXF Question

I have a CXF bean setup for a route that listens for incoming messages on a jetty port. The data format of the bean is in MESSAGE mode. My question is this, if someone sends an invalid message (whether it is malformed XML, improper types, etc), will the to uri=cxf:bean:initiateService/ be the

Writing the servicemix.log within custom java

I was wondering how I can go about writing to this log from within custom java code I have that will be called by the route as a bean. -- View this message in context: http://camel.465427.n5.nabble.com/Writing-the-servicemix-log-within-custom-java-tp5166486p5166486.html Sent from the Camel -

Re: Writing the servicemix.log within custom java

Is there an example of this somewhere, I am fairly new to the majority of this. In the file you mentioned I see # Root logger log4j.rootLogger = INFO, out, osgi:VmLogAppender log4j.throwableRenderer=org.apache.log4j.OsgiThrowableRenderer # CONSOLE appender not used by default

JMS Header Issue

After a lot of testing I have determined the cause of an issue I am having when using 2 different activeMQ JMS endpoints in the same route. Apparently after the first JMS queue is used, the message back will have a bunch of headers set such as JMSCorrelationId, messageId, JMSMessageId, etc. Now

Re: JMS Header Issue

Upon further investigation it seems to not be that simple. The basis of the route is as follows: Send request to JMS Queue A - Splitter on Response - For each split, JMS Queue B So it seems that after A is evaluated, if you reset the JMS headers servicemix will start throwing null pointer

Upgraded to 4.4.1 from 4.4.0 now getting type conversion issue

I installed 4.4.1 and tried to run the bundle which was working previous to the upgrade. It appears camel does not like the conversion of the input stream to the Document type any longer when getting a response from a cxf endpoint. org.apache.camel.InvalidPayloadException: No body available of

Re: Date String Creation

Raul Kripalani wrote Once again, if your messages are XML and you want to manipulate dateTime types, I suggest you use the standard XPath/XQuery functions. It's gonna be simpler and probably faster. Both the XQuery example or the XPath language (with Saxon as a Factory as support for

Re: Date String Creation

So if I declared a bean with id of getLastRunDate that returned a string of the appropriate date format, how do you actually call that in the Spring DSL to set a header? -- View this message in context: http://camel.465427.n5.nabble.com/Date-String-Creation-tp5052753p5056060.html Sent from the

Re: Date String Creation

When using a method call expression, how do you use parameters to the bean methods within the method tag? -- View this message in context: http://camel.465427.n5.nabble.com/Date-String-Creation-tp5052753p5057616.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Date String Creation

For example, lets say I had a value in a route that I could get with some simple xpath, but I needed to pass that as a parameter to a bean that would do some calculation on that value and return it, so that I could then set it as a header or such. Is there a way this could be done without relying

Re: Date String Creation

Is there a way to do it simply through the spring DSL though? I guess I could create a custom processor that just passes on the headers and body after adding a new header with this code in it, but that seems like overkill for this situation. -- View this message in context:

Re: Persistent Header

Thanks, makes sense. I see how to set and get properties via the Exchange java object, is there a way to do this in the Spring DSL on the camel route, or do I need to create a simple processor on each end of the inOut call? -- View this message in context:

Re: Persistent Header

I tried setProperty propertyName=theCode constantABCDE/constant /setProperty to uri=activemq:EXT.REQ/ then in the other part of the route in the same context: from

Re: Using headers and velocity

I have checked the headers and it does seem that the xpath is not returning anything. Given that this is the Spring DSL, and the sessionID element would only fall under the standard namespace I am not sure how to actually declare it in the spring DSL properly. Can I use a mock namespace and

Re: Using headers and velocity

Apparently what I said about using a mock namespace does actually work, so I just set a xmlnx:s to the standard namespace in the xml message and then the xpath worked great. -- View this message in context: http://camel.465427.n5.nabble.com/Using-headers-and-velocity-tp5030214p5032900.html Sent

Persistent Header

I have a route which hits an active MQ point external to my system and outside of my control. I've tried creating a header before the queue, and then capturing it afterwards but the queue I am hitting (actually another instance of Servicemix with activeMQ) does not persist it along with the

Using headers and velocity

I am trying to get a piece of information that is obtained via a cxfEndpoint into a velocity template that will be sent on down the route to other endpoints. Thus far I am trying something very basic and seems like it should work, just storing the sessionId retrieved via xpath as a header and

Re: Using headers and velocity

Well the last part of the route has nothing in the sessionId of the velocity template which is my issue, so I am wondering what is wrong with what I am doing really. -- View this message in context: http://camel.465427.n5.nabble.com/Using-headers-and-velocity-tp5030214p5030870.html Sent from the

Re: Custom Processor with XPath

Good to know. I have the body properly converting to a Document now. I suppose this may end up more of an XPath question, so I apologize in advance but I have looked everywhere for some complicated examples and haven't had much luck. Let's say this is the document that is coming into my custom

Re: Custom Processor with XPath

I changed my code to use the NamespaceContext, unfortunately I am still not getting any matches (tried some simpler strings to test as well). Also, it seems that adding this bit of code really slowed down the processor, though it may just be how many times I have deployed / undeployed the bundle

Re: Custom Processor with XPath

Figured it out. I had forgotten the @ sign in the xpath string. -- View this message in context: http://camel.465427.n5.nabble.com/Custom-Processor-with-XPath-tp5011728p5014998.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: A High Level Data Translation Question

Well I suppose the interesting thing is that when the initial request is sent to the cxf web service endpoint, I am just using a velocity template as the message since it is static, so the cxf endpoint is in MESSAGE format for that. The reply back from the cxf endpoint then would be what needs to

Re: A High Level Data Translation Question

Actually for a bit more clarity, the route is as follows: from uri=timer://hcm?fixedRate=trueamp;period=1h/ to uri=velocity://velocity/hotelRequest.vm /// Static SOAP Message inOut uri=activemqhcm:queue:JMS/HCM.ESB.REQ/// This is a remote version of servicemix where this

Re: A High Level Data Translation Question

I created a custom processor per the links posted previously. Once in a custom processor, is there a way to marshal the message into java objects? Or is there a good way to parse and edit the xml message from within the processor, or should I just write base XML parsing in java? -- View this

Custom Processor with XPath

I am attempting to convert a SOAP message from one message format to another, and along the way calculating and aggregating data. At any rate, I am trying to create a custom processor to do this, within which I will have xpath calls and such. Currently I am running into an issue trying to

Routing Message to remote ActiveMQ

I am trying to send a static message to a JMS queue on another instance of servicemix that a team I work with manages, so I am using a velocity template that is the SOAP message and routing to a remote activeMQ. I have the connection information and have configured it in the spring xml along with

Re: Routing Message to remote ActiveMQ

Thanks, it works now in the spring DSL just by changing it to inOut uri=activemqhcm:queue:JMS/HCM.ESB.REQ/ I appreciate the quick assist! -- View this message in context: http://camel.465427.n5.nabble.com/Routing-Message-to-remote-ActiveMQ-tp5004610p5005119.html Sent from the Camel - Users

A High Level Data Translation Question

This is a fairly basic (but loaded) question I think, but I need some guidance on which way to go and what to look into specifically as I learn more and more about Camel. If in a route I have a large and complicated SOAP XML message that I need to do a significant amount of manipulation and

Re: Type Conversion Question

If I have an existing web service that I need to create a client for, transform the information, then pass it on to another webservice (after heavy data manipulation and changes in format) it seems like POJO would be ideal, at least for the first two pieces. It is my understanding that the client

Re: Type Conversion Question

Makes sense, thanks. This is all still very new to me, so I wasn't sure what the trade off and differences were between POJO and MESSAGE (and PAYLOAD). This was more of a small test. Realistically the jetty endpoint is going to be replaced with a longer camel route which will originate from a

Re: CXF Endpoint issue

The WSDL is generated out of Salesforce.com's platform and should be correct as they enforce it's construction in their environment against standard objects. I uploaded it to my webserver in case you want to look, it's big, but the service declaration and such all look fine to me, so I am not

Re: CXF Endpoint issue

I figured it out, started back at square one and was diligent about all the port, bind and service names and it eventually got deployed properly. Unfortunately this has raised another issue I will post about shortly. -- View this message in context:

CXF Endpoint issue

Greetings, I am running into an issue when deploying a simple camel route within servicemix that contains a cxf endpoint. I am getting the following error. I saw some previous posts on this but I checked over everything suggested in them and can't find the discrepency.