You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "AjayPatil2611 (Jira)" <ji...@apache.org> on 2020/09/03 07:17:00 UTC

[jira] [Created] (CAMEL-15497) Unable to load the External config file for QuickFix component

AjayPatil2611 created CAMEL-15497:
-------------------------------------

             Summary: Unable to load the External config file for QuickFix component
                 Key: CAMEL-15497
                 URL: https://issues.apache.org/jira/browse/CAMEL-15497
             Project: Camel
          Issue Type: Bug
          Components: camel-quickfix
    Affects Versions: 2.24.3
         Environment: OS : Windows10/Ubuntu 20.04/18.04

JDK : AdoptJdk/OpenJdk1.8

Karaf: 4.2.8

Camel Version : 2.24.3

Fix Version : 4.4 on wards.
            Reporter: AjayPatil2611
             Fix For: Future, 3.5.0
         Attachments: image-2020-09-03-12-46-25-226.png, image-2020-09-03-12-46-37-214.png

Hi Team,Hi Team,

{color:#de350b}*Versions used (Karaf 4.2.8 , camel 2.24.3 ,FIX 4.4) (drop down not showing the Fix 4.4 so selected Future /Latest version available* {color}

 i am trying to connect the quick-fix component but required config.cfg file (normally it will be there in classpath), we want to externalize the config.cfg because clients can change the quick-fix(raptor) component details such as (below details might very form environment to environment like DEV/QA/SDN etc.

*SenderCompID/TargetCompID/SocketConnectPort etc.*


*But when try to load from external file*  i.e config.cfg. getting error as unable to load .Even though file path, *i am able to load it properly(karaf/etc/config.cfg*)*[image attached*]

but {color:#de350b}*when i add it to the path with quick-fix component its throwing the error that unable to load.*{color}


Example:
 normally we load it from classpath,*which works perfectly below point 1 and 2*.
Route:

(client/config.cfg in the classpath src/main/resource/client/config.cfg)


*1.* 
  .to("quickfix:client/config.cfg?sessionID=FIX.4.4:BANZAI->EXEC")


*2.* from("quickfix:client/config.cfg?sessionID=FIX.4.4:BANZAI->EXEC&lazyCreateEngine=false&exchangePattern=InOut")

but if you see above client/config.cfg is in classpath of our project. {color:#de350b}*but want to externalize it and place it inside the karaf/etc like other .cfg/.properties file but which is not working.Please do needful as its affecting our release also*{color}

(as usual ,we are externalizing this property for other keys to read by using <cm:property-placeholder)

fixprotocol.cfg

#topic or Queue configuration

Key=value

Key1=value1

+*{color:#de350b}#for fix{color}*+ 

*{color:#57d9a3}cfg.name={color}config.cfg*

*{color:#57d9a3}cfg.path.name{color}=karaf.etc*


*Source code Route:*


public class FixClientRouter extends RouteBuilder {

@PropertyInject(value = {color:#57d9a3}"cfg.name{color}")
private String cfgFileName;

@PropertyInject(value = "{color:#57d9a3}cfg.path.name{color}")
private String cfgpathName; 

@Override public void configure() throws Exception {

String externalPath=System.getProperty(cfgpathName) + File.separator + cfgFileName;

*/*output exernalPath=*
*C:\Ajay\MyDocs\IntegrationProject\DIS\karafsetup\apache-karaf-4.2.8\etc\config.cfg*
**/*

from(ENDPOINT_FIX_COMPONENT)  
.routeId(ENDPOINT_FIX_COMPONENT_ROUTEID)
   .log(LoggingLevel.INFO, LOG_MSG, "fix protocol:connecting to raptor ")   
 .doTry()    
 
 */* Using the existing(created in second route /new session*
 *to explicitly send the on an EVENT (Based on Request)* 
 **/*  

{color:#de350b}*.to("quickfix:"+externalPath+"?sessionID=FIX.4.4:BANZAI->EXEC")//not working //.to("quickfix:file:"+str+"?sessionID=FIX.4.4:BANZAI->EXEC") //not working*{color}   

    .log(LoggingLevel.INFO,"fix converted data sent to raptor successfully!!!!!")
 .endDoTry() 
 .doCatch(Exception.class)    
 //............logs 
 .end()  
 .end(); 
 
 {color:#de350b}*/*For reply from Raptor/IRIS and Session Creation,*{color}
{color:#de350b} *two way communication- Keep Establishing the communication on bundle start)*{color}
{color:#de350b} **/*{color} 
 *from("quickfix:"+externalPath+"?sessionID=FIX.4.4:BANZAI->EXEC&lazyCreateEngine=false&exchangePattern=InOut")*    
 .routeId(ENDPOINT_RAPTOR_CONNECTION_ROUTEID) 
  .filter(PredicateBuilder.or( header(QuickfixjEndpoint.EVENT_CATEGORY_KEY)          .isEqualTo(QuickfixjEventCategory.AdminMessageSent),        header(QuickfixjEndpoint.EVENT_CATEGORY_KEY) 
          .isEqualTo(QuickfixjEventCategory.AppMessageSent),
        header(QuickfixjEndpoint.EVENT_CATEGORY_KEY)          .isEqualTo(QuickfixjEventCategory.AdminMessageReceived),        header(QuickfixjEndpoint.EVENT_CATEGORY_KEY)          .isEqualTo(QuickfixjEventCategory.AppMessageReceived))) 
*.log(LoggingLevel.INFO, LOG_MSG, "heartBeat ...........=${body}")*
 .end();


Error:
C*aused by: java.lang.IllegalArgumentException: Could not load file:C:\Ajay\MyDocs\IntegrationProject\DIS\karafsetup\apache-karaf-4.2.8\etc\config.cfgat org.apache.camel.component.q{color:#de350b}uickfixj.QuickfixjEngine.loadSettings{color}(QuickfixjEngine.java:255) ~[?:?]at org.apache.camel.component.quickfixj.{color:#de350b}QuickfixjComponent.createEndpoint(QuickfixjComponent.java:79) ~[?:?]at{color}* org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:130) ~[!/:2.24.3]at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:705) ~[!/:2.24.3]at org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:80) ~[!/:2.24.3]at org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:227) ~[!/:2.24.3]at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:116) ~[!/:2.24.3]at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:122) ~[!/:2.24.3]at org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:62) ~[!/:2.24.3]at org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:56) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.createProcessor(ProcessorDefinition.java:518) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.createOutputsProcessorImpl(ProcessorDefinition.java:481) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.createOutputsProcessor(ProcessorDefinition.java:448) ~[!/:2.24.3]at org.apache.camel.model.TryDefinition.createProcessor(TryDefinition.java:77) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.makeProcessorImpl(ProcessorDefinition.java:569) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:530) ~[!/:2.24.3]at org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:240) ~[!/:2.24.3]at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:1349) ~[!/:2.24.3]... 25 more

!image-2020-09-03-12-46-37-214.png!

Thanks 

Ajay Patil



--
This message was sent by Atlassian Jira
(v8.3.4#803005)