[
https://issues.apache.org/activemq/browse/CAMEL-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=62184#action_62184
]
Vid Cheruvu edited comment on CAMEL-1350 at 9/28/10 3:15 AM:
-------------------------------------------------------------
+1 for QuickFix. I have manged to run Steve's code and able to persist FIX
messages to Mysql server database and also tested few cases i.e resend. It
worked nicely without much effort.
Below are the code snippet of route builder where orders from Banzai are routed
to EXEC through the FIXGW (Camel-quickfix) . Then exec reports from EXEC are
routed back to BANZAI and also I have added multicast to see FIX message can be
broadcasted to other fix sessions. My camel process can be both acceptor and
initiator.
Great work Steve, it looks great.
//from Banzai (Intiator) to EXEC(Acceptor) through FIXGW (mediator)
from("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI").
filter(PredicateBuilder.and(
header(QuickfixjEndpoint.EVENT_CATEGORY_KEY).isEqualTo(QuickfixjEventCategory.AppMessageReceived),
header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.ORDER_SINGLE))).
to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->EXEC");
//from executor(acceptor) to BANZAI(initiator) through FIXGW
(Mediator)
from("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->EXEC")
.filter(PredicateBuilder.and(
header(QuickfixjEndpoint.EVENT_CATEGORY_KEY).isEqualTo(QuickfixjEventCategory.AppMessageReceived),
header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.EXECUTION_REPORT)))
.multicast()
.stopOnException()
.to("direct:banzai","direct:banzai2")
.end();
from("direct:banzai").to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI");
from("direct:banzai2").to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI2");
---mediator.cfg settings ---
[default]
UseJmx=Y
SocketAcceptProtocol=SOCKET
SocketConnectProtocol=SOCKET
PersistMessages=Y
StartTime=00:00:00
EndTime=00:00:00
HeartBtInt=30
ScreenLogEvents=N
ScreenLogShowIncoming=N
ScreenLogShowOutgoing=N
ValidateUserDefinedField=N
JdbcURL=jdbc:mysql://localhost:3306/quickfix
JdbcDriver=com.mysql.jdbc.Driver
JdbcUser=root
JdbcPassword=
[session]
ConnectionType=initiator
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=EXEC
SocketConnectHost=127.0.0.1
SocketConnectPort=1100
[session]
ConnectionType=acceptor
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=BANZAI2
SocketAcceptPort=7002
[session]
ConnectionType=acceptor
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=BANZAI
SocketAcceptPort=10000
was (Author: v_cher...@hotmail.com):
+1 for QuickFix. I have manged to run Steve's code and able to persist FIX
messages to Mysql server database and also tested few cases i.e resend. It
worked nicely without much effort.
Below are the code snippet of route builder where orders from Banzai are routed
to EXEC through the FIXGW (Camel-quickfix) . Then exec reports from EXEC are
routed back to BANZAI and also I have added multicast to see FIX message can be
broadcasted to other fix sessions. My camel process can be both acceptor and
initiator.
Great work Steve, it looks great.
//from Banzai (Intiator) to EXEC(Acceptor) through FIXGW (mediator)
from("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI").
filter(PredicateBuilder.and(
header(QuickfixjEndpoint.EVENT_CATEGORY_KEY).isEqualTo(QuickfixjEventCategory.AppMessageReceived),
header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.ORDER_SINGLE))).
to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->EXEC");
//from executor(acceptor) to BANZAI(initiator) through FIXGW
(Mediator)
from("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->EXEC")
.filter(PredicateBuilder.and(
header(QuickfixjEndpoint.EVENT_CATEGORY_KEY).isEqualTo(QuickfixjEventCategory.AppMessageReceived),
header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.EXECUTION_REPORT)))
.multicast()
.stopOnException()
.to("direct:banzai","direct:banzai2")
.end();
from("direct:banzai").to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI");
from("direct:banzai2").to("quickfixj:quickfix/mediator.cfg?sessionID=FIX.4.2:FIXGW->BANZAI2");
---mediator.cfg settings ---
[default]
UseJmx=Y
SocketAcceptProtocol=SOCKET
SocketConnectProtocol=SOCKET
PersistMessages=Y
StartTime=00:00:00
EndTime=00:00:00
HeartBtInt=30
ScreenLogEvents=N
ScreenLogShowIncoming=N
ScreenLogShowOutgoing=N
ValidateUserDefinedField=N
JdbcURL=jdbc:mysql://localhost:3306/quickfix
JdbcDriver=com.mysql.jdbc.Driver
JdbcUser=root
JdbcPassword=
#
# Initiator for simulating a trader
#
[session]
ConnectionType=initiator
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=EXEC
SocketConnectHost=127.0.0.1
SocketConnectPort=1100
#
# Acceptor for simulating the market
#
[session]
ConnectionType=acceptor
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=BANZAI2
SocketAcceptPort=7002
[session]
ConnectionType=acceptor
BeginString=FIX.4.2
SenderCompID=FIXGW
TargetCompID=BANZAI
SocketAcceptPort=10000
> camel-quickfix component in apache camel distribution
> -----------------------------------------------------
>
> Key: CAMEL-1350
> URL: https://issues.apache.org/activemq/browse/CAMEL-1350
> Project: Apache Camel
> Issue Type: New Feature
> Environment: <properties>
> <camel-version>2.0-SNAPSHOT</camel-version>
> <fuse-version>2.x-fuse-SNAPSHOT</fuse-version>
> <activemq-version>5.2.0</activemq-version>
> <quickfix-version>1.3.3</quickfix-version>
> <mina-version>1.1.0</mina-version>
> <slf4j-version>1.5.6</slf4j-version>
> </properties>
> Reporter: Charles Moulliard
> Assignee: Hadrian Zbarcea
> Fix For: 2.5.0
>
> Attachments: camel-quickfix-2.zip, camel-quickfix.patch,
> camel-quickfix.zip, camel-quickfix.zip, QuickFixDataFormat.java,
> reportincident.quickfix.zip
>
>
> Hi,
> ATTENTION: Ignoring converter type: org.apache.camel.fix.FixConverter as a
> dependent class could not be found: java.lang.NoClassDefFoundError:
> biz/c24/io/api/data/DataType
> java.lang.NoClassDefFoundError: biz/c24/io/api/data/DataType
> at java.lang.Class.getDeclaredMethods0(Native Method)
> at java.lang.Class.privateGetDeclaredMethods(Class.java:2427)
> at java.lang.Class.getDeclaredMethods(Class.java:1791)
> at
> org.apache.camel.impl.converter.AnnotationTypeConverterLoader.loadConverterMethods(AnnotationTypeConverterLoader.java:147)
> at
> org.apache.camel.impl.converter.AnnotationTypeConverterLoader.load(AnnotationTypeConverterLoader.java:78)
> at
> org.apache.camel.impl.converter.DefaultTypeConverter.checkLoaded(DefaultTypeConverter.java:260)
> at
> org.apache.camel.impl.converter.DefaultTypeConverter.convertTo(DefaultTypeConverter.java:95)
> at
> org.apache.camel.impl.converter.DefaultTypeConverter.convertTo(DefaultTypeConverter.java:71)
> at
> org.apache.camel.util.IntrospectionSupport.convert(IntrospectionSupport.java:263)
> at
> org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:221)
> at
> org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:188)
> at
> org.apache.camel.impl.DefaultComponent.setProperties(DefaultComponent.java:213)
> at
> org.apache.camel.component.file.GenericFileComponent.createEndpoint(GenericFileComponent.java:63)
> at
> org.apache.camel.component.file.GenericFileComponent.createEndpoint(GenericFileComponent.java:33)
> at
> org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:81)
> at
> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:330)
> at
> org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:54)
> at org.apache.camel.model.RouteType.resolveEndpoint(RouteType.java:96)
> at
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106)
> at
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112)
> at org.apache.camel.model.FromType.resolveEndpoint(FromType.java:72)
> at
> org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:81)
> at org.apache.camel.model.RouteType.addRoutes(RouteType.java:239)
> at org.apache.camel.model.RouteType.addRoutes(RouteType.java:86)
> at
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:661)
> at
> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:651)
> at
> org.apache.camel.spring.SpringCamelContext.maybeDoStart(SpringCamelContext.java:166)
> at
> org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:161)
> at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49)
> at
> org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:96)
> at
> org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:115)
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78)
> at
> org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49)
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)
> at
> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)
> at
> org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736)
> at
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:383)
> at
> org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
> at
> org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:93)
> at
> org.apache.camel.spring.Main.createDefaultApplicationContext(Main.java:232)
> at org.apache.camel.spring.Main.doStart(Main.java:186)
> at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49)
> at org.apache.camel.util.MainSupport.run(MainSupport.java:121)
> at org.apache.camel.util.MainSupport.run(MainSupport.java:299)
> at org.apache.camel.spring.Main.main(Main.java:98)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.apache.camel.maven.RunMojo$1.run(RunMojo.java:396)
> at java.lang.Thread.run(Thread.java:619)
> The org.apache.camel.fix.FixConverter class uses proprietary classes :
> import biz.c24.io.api.data.BooleanDataType;
> import biz.c24.io.api.data.CharDataType;
> import biz.c24.io.api.data.ComplexDataObject;
> import biz.c24.io.api.data.ComplexDataType;
> import biz.c24.io.api.data.DataType;
> import biz.c24.io.api.data.DateDataType;
> import biz.c24.io.api.data.Element;
> import biz.c24.io.api.data.IntDataType;
> import biz.c24.io.api.data.NumberDataType;
> import biz.c24.io.api.data.StringDataType;
> import biz.c24.io.api.presentation.TextualSource;
> import biz.c24.io.fix42.NewOrderSingleElement;
> Except if those classes are part of open source community but How can I use
> this component without Artix Data Service ?
> ex config :
> <route>
> <from uri="fixserver:banzai-to-camel.cfg" />
> <to uri="log:quickfix" />
> </route>
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
