Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Enabling logging in spring integration utility

Below I have the program to send a message and consume a message from queue, right now I have commented out the sending part and only want to consume the messages from queue

Now I want to enable logging in the below program such that a log file is generated in my c: drive and inside that log file it should indicate that what message it is consuming at what time stamp please advise how to configure logging in the below configuration file

<?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:int="http://www.springframework.org/schema/integration"
    xmlns:jms="http://www.springframework.org/schema/integration/jms"
    xmlns:file="http://www.springframework.org/schema/integration/file"
    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/integration http://www.springframework.org/schema/integration/spring-integration.xsd 
    http://www.springframework.org/schema/integration/jms 
    http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd 
    http://www.springframework.org/schema/integration/spring-integration.xsd
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/integration/file
    http://www.springframework.org/schema/integration/file/spring-integration-file.xsd    
    http://www.springframework.org/schema/context/spring-context.xsd">


    <int:poller id="poller" default="true">
        <int:interval-trigger interval="200" />
    </int:poller>



    <int:channel id="input">
        <int:queue capacity="10" />
    </int:channel>

    <bean id="tibcoEMSJndiTemplate" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <props>
                <prop key="java.naming.factory.initial">com.tibco.tibjms.naming.TibjmsInitialContextFactory
                </prop>
                <prop key="java.naming.provider.url">tcp://lsdrtems2.fm.crdgrp.net:7333</prop>
                <prop key="java.naming.security.principal">acfgtir</prop>
                <prop key="java.naming.security.credentials">acfgtir</prop>
            </props>
        </property>
    </bean>

    <bean id="tibcoEMSConnFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="tibcoEMSJndiTemplate" />
        </property>
        <property name="jndiName">
            <value>GenericConnectionFactory</value>
        </property>
    </bean>

    <bean id="tibcosendJMSTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory">
            <ref bean="tibcoEMSConnFactory" />
        </property>
        <property name="defaultDestinationName">
            <value>acfgtirrtyation.ioa.swretift_publish_poc1</value>
        </property>
        <property name="pubSubDomain">
            <value>false</value>
        </property>
        <property name="receiveTimeout">
            <value>120000</value>
        </property>
    </bean>




    <!-- <jms:outbound-channel-adapter channel="input" 
        destination-name="acfgtirrtyation.ioa.swretift_publish_poc1" connection-factory="tibcoEMSConnFactory" /> -->

<int:channel id="objetChannel"></int:channel>
<int:channel id="StringChannel"></int:channel>
<int:channel id="jmsInChannel" />



<jms:message-driven-channel-adapter id="jmsIn" concurrent-consumers="10"
        destination-name="acfgtirrtyation.ioa.swretift_publish_poc1"  connection-factory="tibcoEMSConnFactory" extract-payload="false"
        channel="jmsInChannel" />

    <int:payload-type-router input-channel="jmsInChannel">
    <int:mapping type="javax.jms.ObjectMessage" channel="objetChannel" />
     <int:mapping type="javax.jms.TextMessage" channel="StringChannel" />
    </int:payload-type-router>



 <file:outbound-channel-adapter id="filesoutOject"  channel="objetChannel" directory="C:\\abcsaral"
 filename-generator="generatorr" />



 <file:outbound-channel-adapter id="filesoutString"  channel="StringChannel" directory="C:\\abcsaral"
 filename-generator="generatorr" />

<bean id="generatorr" class="com.abs.tibco.TimestampTextGenerator">
    </bean>


</beans>
like image 258
sss Avatar asked Mar 13 '23 03:03

sss


1 Answers

Add log4j (or logback, or any java logging system supported by commons-logging) to your classpath and configure it to log a DEBUG level for category org.springframework.integration.

Or you can add a wire tap to the channel and route it to a Logging channel adapter

<int:channel id="in">
    <int:interceptors>
        <int:wire-tap channel="logger"/>
    </int:interceptors>
</int:channel>

<int:logging-channel-adapter id="logger" level="DEBUG"/>
like image 135
Gary Russell Avatar answered Apr 26 '23 06:04

Gary Russell