Thanks a lot, it worked like a charm.
I added two fields to the config field (Username and Password) and read them
from the componet so they wouldn't be hardcoded. Here's the processor:
public class FixLoginRequestProcessor implements Processor
{
public void process(Exchange exchange) thr
Hi, Im trying to create a system that converts http messages to Fix messages
to send to an Exchange (my systems acts as the initiator). What I cannot
figure is how I can insert user and password fields to FIX's Logon message
(or for that matter, how can I start the FIX connection on demand). I tri
Hi, I'm in the process of deploying a Camel solution to it's destination
server. It has 6 routes and is essentially a Fix to HTTP converter (it uses
the FIX and Jetty components). What surprises me is the high CPU use (about
50% continuous on a dual core, dual processor Xeon server) when the router
Claus, thanks for your response. I tried to use
throwException(simple("${exception}"))
but it gives me a compile time error:
The method throwException(Exception) in the type
ProcessorDefinition is not applicable for the arguments
(SimpleBuilder)
I'm using Camel 2.7.2.
Yours
Pablo
--
View t
Hi,
I've a situation where a route can throw many kinds of exceptions, say A, B,
and C. If exception is class A I should let it pass; if it's any other kind
of exception I should throw a new exception of class A.
doTry().
.
.
.
doCatch(A.class).
//Let it pass forward
doCatch(Exception.cl
Hi, I'm developing a info distribution system that gets an XML document with
data entries and then has to enrich it with nodes that are obtained from a
SQL database. The SQL query has to be generated using paramethers from data
inside the original XML document (they are properties of some of the no
Hi, I'm using a detour so that if a message has a "suscription" flag it then
connects to a database and creates an entry (in addition to the normal
processing of the message).
from("quickfix:marketdata.cfg").
filter(header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.MARKET_DATA_REQUEST))
Hi, I created CAMEL-4278. It adds one method to convert from byte[] to
Message, and one to convert from quickfixj.Message to InputStream. I had to
add them both to be able to marshal/unmarshal quickfixj messages with Bindy.
Pablo
--
View this message in context:
http://camel.465427.n5.nabble.com
I solved the problem adding a type converter from byte array (the result of
Bindy's marshal) to quickfix Message. The QuickFixConverter that cames with
the examples has a method to convert from String to quickfix Message so it
wasn't used.
--
View this message in context:
http://camel.465427.n5.n
Hi, I finally managed to go forward a few steps by modifying the quickfix
converter. The route I'm building looks like this:
from("quickfix:config.cfg").
filter(
header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.ORDER_SINGLE)).
unmarshal(camelDataFormat).
to("jetty:http://loc
10 matches
Mail list logo
