...
The JMS endpoint is the implementation of the transport adapter.
There are several ways to add JMS connectivity into the FEJ container.
...
The sysconf/fej-jms.xml configuration file already contains the basic configuration for the JMS adapter:
| Code Block | ||
|---|---|---|
| ||
<bean id="jmsProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean"
p:location="classpath:jms-adaptor.properties"/>
<bean id="jmsConfig" class="com.epam.fixengine.jms.config.Config"
c:prefix="jms.adaptor"
c:properties-ref="jmsProperties">
</bean>
<bean id="jmsConfigRegister" class="com.epam.fej.jms.DefaultJmsConfigsRegister"
p:jmsManager-ref="jmsAdaptorManager"
c:config-ref="jmsConfig" init-method="init"/>
<bean id="jmsClientFactory" class="com.epam.fixengine.jms.client.JMSClientFactory" factory-method="getInstance"/>
<bean id="jmsAdaptorManager" class="com.epam.fej.jms.JmsAdapterManager"
c:endpointRegistry-ref="endpointRegistry"
c:clientFactory-ref="jmsClientFactory"
depends-on="rulesConfigManager"/> |
...
There are several ways to add Kafka connectivity into the FIXEdge/J container. The sysconf/fej-kafka.xml configuration file already contains the basic configuration for the Kafka adapter:
| Code Block | ||||
|---|---|---|---|---|
| ||||
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:c="http://www.springframework.org/schema/c"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="kafkaProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean"
p:location="classpath:kafka-adaptor.properties"/>
<bean id="kafkaConfig" class="com.epam.fixengine.kafka.config.Config"
c:prefix="kafka"
c:properties-ref="kafkaProperties">
</bean>
<bean id="kafkaConfigRegister" class="com.epam.fej.kafka.DefaultKafkaConfigsRegister"
p:clientManager-ref="kafkaClientManager"
c:config-ref="kafkaConfig"/>
<bean id="kafkaClientFactory" class="com.epam.fixengine.kafka.client.ClientFactory" factory-method="getInstance"/>
<bean id="kafkaClientManager" class="com.epam.fej.kafka.DefaultKafkaClientManager"
c:endpointRegistry-ref="endpointRegistry"
c:clientFactory-ref="kafkaClientFactory"
c:messageEventPool-ref="messageEventPool"
depends-on="rulesConfigManager"/>
</beans> |
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:c="http://www.springframework.org/schema/c"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<bean id="smtpProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean"
p:location="classpath:smtp-adaptor.properties"/>
<bean id="smtpConfigProvider" class="com.epam.fej.smtp.SMTPConfigProvider"
c:properties-ref="smtpProperties">
</bean>
<util:properties id="velocityProperties">
<prop key="resource.loader">class</prop>
<prop key="class.resource.loader.class">org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader</prop>
</util:properties>
<bean id="velocityEngine" class="org.apache.velocity.app.VelocityEngine">
<constructor-arg ref="velocityProperties"/>
</bean>
<bean id="simpleTemplateConverter" class="com.epam.fej.smtp.TemplateEmailConverter" scope="prototype"
p:velocityEngine-ref="velocityEngine">
</bean>
<bean id="mimeTemplateConverter" class="com.epam.fej.smtp.TemplateMimeEmailConverter" scope="prototype"
p:velocityEngine-ref="velocityEngine">
</bean>
<context:component-scan base-package="com.epam.fej.smtp"/>
</beans> |
...