JMS concept

[vijaya nalluri]

Hi folks,

I am new to JMS concept, When I have web.xml, applicationContext, dev_context.xml how all the three are related can I load all the three in container?

Waiting for you answer?

Thanks,
Vijaya

[Tim Moores]

In the Java world, JMS is understood to mean the Java Message Service; is that what you mean by it? If yes, please clarify what its relationship with the files you mention is (I don't see any direct connection). If no, please elaborate what you actually meant.

[vijaya nalluri]

I have applicationContext-test.xml like the following

<?xml version="1.0" encoding="UTF-8"?> <!-- ~ Copyright 2011: Thomson Reuters Global Resources. All Rights Reserved. ~ Proprietary and Confidential information of TRGR. Disclosure, Use or Reproduction without the written authorization of TRGR is prohibited --> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd"> <context:component-scan base-package="com.thomson.judicial" /> <!-- JMS Request --> <!-- <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer102"> <property name="maxConcurrentConsumers" value="5"/> <property name="connectionFactory" ref="myConnectionFactory" /> <property name="destination" ref="requestQueue" /> <property name="messageListener" ref="PreDocketMessageListener"/> <property name="cacheLevelName" value="CACHE_SESSION"/> </bean> <bean id="myConnectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> <property name="targetConnectionFactory" ref="connectionFactory"/> <property name="username" value=" "/> <property name="password" value=" "/> </bean> <bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName" value="java:comp/env/jms/PreDocketPublisherQueueConnectionFactory"/> </bean> <bean id="requestQueue" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName" value="java:comp/env/jms/PreDocketPublisherRequestQueue" /> </bean>--> <bean id="errorServiceClient" class="com.thomson.judicial.predocket.publisher.service.error.ErrorServiceClientImpl" /> <bean id="auditServiceClient" class="com.thomson.judicial.predocket.publisher.service.audit.AuditServiceClientImpl" /> <bean id="securityServiceClient" class="com.thomson.judicial.predocket.publisher.service.security.SecurityServiceClientImpl" /> <!-- JMS Holmes Activity Queue Set up --> <bean id="holmesJmsTemplate" class="org.springframework.jms.core.JmsTemplate102"> <property name="connectionFactory"> <bean class="org.springframework.jms.connection.SingleConnectionFactory"> <property name="targetConnectionFactory"> <ref local="holmesJmsInternalQueueConnectionFactory" /> </property> </bean> </property> </bean> <bean id="holmesJmsInternalQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiTemplate"> <ref bean="holmesJndiTemplate" /> </property> <property name="jndiName"> <value>VERITY</value> </property> </bean> <bean id="holmesJndiTemplate" class="org.springframework.jndi.JndiTemplate"> <property name="environment"> <props> <prop key="java.naming.factory.initial">com.ibm.mq.jms.context.WMQInitialContextFactory</prop> <prop key="java.naming.provider.url">VERITY.INT.WESTGROUP.COM:1414/CLIENTCONNECTION</prop> </props> </property> </bean> <bean id="holmesHandler" class="com.thomson.judicial.predocket.publisher.handler.HolmesHandler" /> <bean id="holmesHandlerMessageUtility" class="com.thomson.judicial.predocket.publisher.util.HolmesHandlerMessageUtility"> <property name="jmsTemplate" ref="holmesJmsTemplate" /> <property name="destination" ref="holmesASQueue" /> </bean> <bean id="holmesASQueue" class="com.ibm.mq.jms.MQQueue" > <constructor-arg value="VERITY"/> <constructor-arg value="CONTECH.DOCKETS.STATS.TEST" /> </bean> <!-- Summary Service Queue connection Factory and Queue Setup --> <bean id="summaryService" class="com.thomson.judicial.predocket.publisher.util.SummaryService" /> <bean id="summaryHandler" class="com.thomson.judicial.predocket.publisher.handler.SummaryHandler" /> <bean id="summaryServiceConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName" value="java:comp/env/jms/SummaryServiceConnectionFactory"/> </bean> <bean id="summaryServiceMessageUtility" class="com.thomson.judicial.predocket.publisher.util.SummaryServiceMessageUtility"> <property name="jmsTemplate" ref="summaryServiceJmsTemplate" /> <property name="destination" ref="summaryServiceQueue" /> </bean> <bean id="summaryServiceJmsTemplate" class="org.springframework.jms.core.JmsTemplate102"> <property name="connectionFactory" ref="summaryServiceConnectionFactory" /> </bean> <bean id="summaryServiceQueue" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName" value="java:comp/env/jms/SummaryServiceQueue" /> </bean> <!-- Initialize log4j output file --> <bean id="setLog4JOutputFileBean" class="com.thomson.judicial.predocket.publisher.util.SetLog4JOutputFile" init-method="initialize" /> <!-- Data source for all environments --> <jee:jndi-lookup id="preDocketPublisherDataSource" jndi-name="jdbc/PreDocketPublisherDatabase" resource-ref="true" /> <bean id="courtConfigEntityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <property name="persistenceXmlLocation" value="classpath:persistence.xml" /> <property name="persistenceUnitName" value="courtconfig"/> <property name="dataSource" ref="preDocketPublisherDataSource" /> <property name="jpaVendorAdapter"> <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"> <property name="databasePlatform" value="org.hibernate.dialect.Oracle10gDialect" /> <property name="showSql" value="true" /> <property name="generateDdl" value="false" /> </bean> </property> </bean> <bean id="txManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="courtConfigEntityManagerFactory" /> </bean> <bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" /> <bean id="courtConfigBean" class="com.thomson.judicial.predocket.court.config.CourtConfigurationBean" init-method="initialize" /> <!-- Security Service init bean --> <bean id="securityServiceInitBean" class="com.thomson.judicial.predocket.publisher.service.security.SecurityServiceInitBean" init-method="initialize" /> <bean id="preDocketMessageListener" class="com.thomson.judicial.predocket.publisher.jms.PreDocketMessageListener"> </bean> <bean id="preDocketManager" class="com.thomson.judicial.predocket.publisher.manager.PreDocketManager"> </bean> <bean id="loadManager" class="com.thomson.judicial.predocket.common.manager.LoadManager"> </bean> <bean id="novusLoadManager" class="com.thomson.judicial.predocket.publisher.manager.NovusLoadManager"> </bean> <bean id="docketManager" class="com.thomson.judicial.predocket.publisher.manager.DocketManager"> </bean> <bean id="updateManager" class="com.thomson.judicial.predocket.update.service.UpdateManager"> </bean> <bean id="novusSlimAPILoadManager" class="com.thomson.judicial.predocket.publisher.manager.NovusSlimAPILoadManager"> </bean> <bean id="preDocketDeleteManager" class="com.thomson.judicial.predocket.publisher.manager.PreDocketDeleteManager"> </bean> <bean id="docketNumberHandler" class="com.thomson.judicial.predocket.update.service.DocketNumberHandler"> </bean> <bean id="courtNameHandler" class="com.thomson.judicial.predocket.update.service.CourtNameHandler"> </bean> <!-- Represents the job that will be executed at certain times. This job refreshes court config beans. --> <bean name="refreshCourtConfigUsingQuartz" class="org.springframework.scheduling.quartz.JobDetailBean"> <property name="jobClass" value="com.thomson.judicial.predocket.court.config.RefreshCourtConfigUsingQuartz" /> </bean> <!-- Defines the trigger that will fire the job associated with it. This trigger also has information on when the job will be fired based on property cronExpression. --> <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"> <property name="jobDetail" ref="refreshCourtConfigUsingQuartz" /> <property name="cronExpression" value="0 0 * * * ?" /> </bean> <bean id="preDocketCleanupManager" class="com.thomson.judicial.predocket.cleanup.PreDocketCleanupManager" /> <bean name="startPreDocketCleanupManagerUsingQuartz" class="org.springframework.scheduling.quartz.JobDetailBean"> <property name="jobClass" value="com.thomson.judicial.predocket.cleanup.StartPreDocketCleanupManagerUsingQuartz" /> </bean> <bean id="preDocketCleanupCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"> <property name="jobDetail" ref="startPreDocketCleanupManagerUsingQuartz"/> <property name="cronExpression" value="0 0 7 * * ?"/> </bean> <!-- Represents the scheduler. The trigger is registered with the scheduler. Also creates Spring managed beans for use by the job. If these beans are not defined as part of property schedulerContextAsMap, the job does not have access to the Spring managed beans created during application startup. This is because the job runs as a separate thread. --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="cronTrigger" /> <ref bean="preDocketCleanupCronTrigger" /> </list> </property> <property name="schedulerContextAsMap"> <map> <entry key="courtConfigBean" value-ref="courtConfigBean"/> <entry key="preDocketCleanupManager" value-ref="preDocketCleanupManager"/> </map> </property> </bean> <bean id="preDocketPublisherStatusBean" class="com.thomson.judicial.predocket.publisher.bean.PreDocketPublisherStatusBean" init-method="initialize"/> <!-- Represents the job that will be executed at certain times. This job refreshes court PreDocketPublisherStatus beans. --> <bean name="refreshPreDocketPublisherStatusUsingQuartz" class="org.springframework.scheduling.quartz.JobDetailBean"> <property name="jobClass" value="com.thomson.judicial.predocket.court.config.RefreshPreDocketPublisherStatusUsingQuartz" /> </bean> <!-- Defines the trigger that will fire the job associated with it. This trigger also has information on when the job will be fired based on property cronExpression. --> <bean id="cronTriggerForPreDocketPublisherStatus" class="org.springframework.scheduling.quartz.CronTriggerBean"> <property name="jobDetail" ref="refreshPreDocketPublisherStatusUsingQuartz" /> <property name="cronExpression" value="* 5 * * * ?" /> </bean> <!-- Represents the scheduler. The trigger is registered with the scheduler. Also creates Spring managed beans for use by the job. If these beans are not defined as part of property schedulerContextAsMap, the job does not have access to the Spring managed beans created during application startup. This is because the job runs as a separate thread. --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="cronTriggerForPreDocketPublisherStatus" /> </list> </property> <property name="schedulerContextAsMap"> <map> <entry key="preDocketPublisherStatusBean" value-ref="preDocketPublisherStatusBean"/> </map> </property> </bean> <!-- Begin Metadoc Changes for WLN Alerts --> <bean id="metadocPropertyBean" class="com.thomson.judicial.predocket.publisher.wln.metadoc.bean.MetadocPropertyBean"> <property name="requestQueueServer" value="${request.queue.server}"/> <property name="requestQueueName" value="${request.queue.name}"/> <property name="requestQueuePort" value="${request.queue.port}"/> <property name="requestQueueTimeout" value="${request.timeout}"/> <property name="metadocRequestProcessingTime" value="${request.processing.time}"/> <property name="responseQueueServer" value="${response.queue.server}"/> <property name="responseQueueName" value="${response.queue.name}"/> <property name="responseQueuePort" value="${response.queue.port}"/> <property name="responseQueueChannel" value="${response.queue.channel}"/> <property name="responseQueueTimeout" value="${response.queue.timeout}"/> <property name="errorQueueServer" value="${error.queue.server}"/> <property name="errorQueueName" value="${error.queue.name}"/> <property name="errorQueueChannel" value="${error.queue.channel}"/> <property name="errorQueuePort" value="${error.queue.port}"/> <property name="srcFtpServer" value="${src.ftp.server}"/> <property name="srcFtpUserName" value="${src.ftp.username}"/> <property name="srcFtpPassword" value="${src.ftp.password}"/> <property name="destFtpServer" value="${dest.ftp.server}"/> <property name="destFtpServerUserName" value="${dest.ftp.server.username}"/> <property name="destFtpServerPassword" value="${dest.ftp.server.password}"/> <property name="renderedFileNamePrefix" value="${rendered.file.name.prefix}"/> <property name="errorFileNamePrefix" value="${error.file.name.prefix}"/> <property name="metadocNotifyEmail" value="${metadoc.notify.email}"/> <property name="fromMail" value="${from.email}"/> </bean> <!-- Metadoc Service Queue Values --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="ignoreUnresolvablePlaceholders" value="true"/> <property name="locations"> <list> <jee:jndi-lookup jndi-name="java:comp/env/metadoc.properties.location"/> </list> </property> </bean> <bean id="metadocService" class="com.thomson.judicial.predocket.publisher.wln.metadoc.service.MetadocService" /> <!-- End Metadoc Changes for WLN Alerts --> </beans> in the same way test_context.xml as in the following way <Context path="/PreDocketPublisher"> <!-- Copyright 2011: Thomson Reuters Global Resources. All Rights Reserved. ~ Proprietary and Confidential information of TRGR. Disclosure, Use or Reproduction without the written authorization of TRGR is prohibited --> <!-- JMS Resources --> <Resource name="jms/PreDocketPublisherQueueConnectionFactory" auth="Container" type="com.ibm.mq.jms.MQQueueConnectionFactory" factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory" HOST="j3testmq.int.westgroup.com" TRAN="1" CHAN="CLIENTCONNECTION"/> <Resource name="jms/PreDocketPublisherRequestQueue" auth="Container" type="com.ibm.mq.jms.MQQueue" factory="com.ibm.mq.jms.MQQueueFactory" QU="CONTECH.PREDOCKET.REQ.TEST"/> <!-- Summary Service Queue Connection Factory and Queue Setup <Resource name="jms/SummaryServiceConnectionFactory" auth="Container" type="com.ibm.mq.jms.MQQueueConnectionFactory" factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory" HOST="j3testmq.int.westgroup.com" TRAN="1" CHAN="CLIENTCONNECTION"/> <Resource name="jms/SummaryServiceQueue" auth="Container" type="com.ibm.mq.jms.MQQueue" factory="com.ibm.mq.jms.MQQueueFactory" QU="CONTECH.JDG.SUMMARY.TEST"/> --> <!-- Holmes Activity Set Queue --> <Resource name="jms/HolmesAQSConnectionFactory" auth="Container" type="com.ibm.mq.jms.MQQueueConnectionFactory" factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory" HOST="j3testmq.int.westgroup.com" TRAN="1" CHAN="CLIENTCONNECTION"/> <Resource name="jms/HolmesASQueue" auth="Container" type="com.ibm.mq.jms.MQQueue" factory="com.ibm.mq.jms.MQQueueFactory" QU="CONTECH.DOCKETS.STATS.TEST"/> <!-- NY Redev changes --> <!-- PBUI Activity Set Queue --> <Resource name="jms/PBUIAQSConnectionFactory" auth="Container" type="com.ibm.mq.jms.MQQueueConnectionFactory" factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory" HOST="jdgtestmq.int.westgroup.com" TRAN="1" CHAN="CLIENTCONNECTION"/> <Resource name="jms/PBUIASQueue" auth="Container" type="com.ibm.mq.jms.MQQueue" factory="com.ibm.mq.jms.MQQueueFactory" QU="CONTECH.DOCKETS.PREDOCKETS"/> <!-- Pre Docket Publisher Test Database --> <Resource name="jdbc/PreDocketPublisherDatabase" auth="Container" type="oracle.jdbc.pool.OracleDataSource" factory="oracle.jdbc.pool.OracleDataSourceFactory" driverClassName="oracle.jdbc.driver.OracleDriver" url="jdbc:oracle:thin:@(DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = c950htbcpdbtf.int.westgroup.com)(PORT = 1521))(CONNECT_DATA =(SERVER = DEDICATED)(SERVICE_NAME = pre_docket_pub_test.int.westgroup.com)))" user="pre_docket_pub_user" password="pre_docket_pub_user" connectionCachingEnabled="true" connectionCacheName="PreDocketPublisherDatabaseTest-cache" connectionCacheProperties="{MinLimit=25, MaxLimit=100, InitialLimit=0}"/> <!-- WLN Alerts Metadoc Service property file --> <Environment name="metadoc.properties.location" value="classpath:metadoc.test.properties" type="java.lang.String" override="false" /> <Environment name="haload.properties.location" value="classpath:HALoad.TEST.properties" type="java.lang.String" override="false" /> <!-- Security Service URL --> <Environment name="security.service.url" value="http://qa.cpp.securityservice.int.westgroup.com/SecurityService/services/SecurityServicePort" type="java.lang.String" override="false" /> <!-- Audit Service URL --> <Environment name="audit.service.url" value="http://qa.cpp.auditservice.int.westgroup.com/AuditService/services/AuditServicePort" type="java.lang.String" override="false" /> <!-- Error Service URL --> <Environment name="error.service.url" value="http://qa.cpp.errorservice.int.westgroup.com/ErrorService/services/ErrorServicePort" type="java.lang.String" override="false" /> <Environment name="summary.service.url" value="http://test.predocket.publisher.judicial.int.westgroup.com:8182/PreDocketPublisher/SummaryService/" type="java.lang.String" override="false" /> <Environment name="metadata.service.url" value="http://uat.mds.judicial.int.westgroup.com/MetadataService/knos" type="java.lang.String" override="false" /> <!-- Holmes Service Starts --> <Environment name="holmes.service.url" value="http://test.docketstracking.int.westgroup.com/DocketsTracking/DeleteService" type="java.lang.String" override="false" /> <!-- Holmes Service Ends --> <!-- Log4j target file --> <Environment name="log4j.outputFile" value="/ct-data/judicial/logs/PreDocketPublisher/predocketpublisher.log" type="java.lang.String" override="false" /> <Environment name="base.publishing.dir" value="/prtest/data/novusload/" type="java.lang.String" override="false" /> <Environment name="datacap.login.credentials" value="c966qzbcthodf,datacap,Heritag04" type="java.lang.String" override="false" /> <Environment name="publishing.retro.mode" value="off" type="java.lang.String" override="false" /> <Environment name="retry_value" value="4" type="java.lang.String" override="false" /> <Environment name="error_service_retry_count" value="2" type="java.lang.String" override="false" /> <Environment name="error_service_sleep_sec" value="3" type="java.lang.String" override="false" /> <Environment name="state.predocket.dir" value="/ct-data/prod/dockets/source/statedocket/pre-dockets_lower_env/TEST/COURT_NAME/datacap_pre_new/" type="java.lang.String" override="false" /> <Environment name="feddct.predocket.dir" value="/ct-data/prod/dockets/source/feddctdocket/pre-dockets_lower_env/TEST/COURT_NAME/datacap_pre_new/" type="java.lang.String" override="false" /> <Environment name="base.work.dir" value="/prtest/data/work/" type="java.lang.String" override="false" /> <Environment name="novus.environment" value="client" type="java.lang.String" override="false" /> <Environment name="novus.collection.owner" value="WestDockets" type="java.lang.String" override="false" /> <Environment name="ny.novus.collection.owner" value="ContentTech" type="java.lang.String" override="false" /> <Environment name="novus.collection.password" value="West" type="java.lang.String" override="false" /> <Environment name="novus.load.retry" value="15" type="java.lang.String" override="false" /> <Environment name="novus.load.delay" value="15" type="java.lang.String" override="false" /> <Environment name="updateService.email.from" value="[e-mail]" type="java.lang.String" override="false" /> <Environment name="updateService.emailGroup.To" value="[e-mail],[e-mail]" type="java.lang.String" override="false" /> <Environment name="updateService.trialDoc.emailGroup.To" value="[e-mail],[e-mail],[e-mail]" type="java.lang.String" override="false" /> <Environment name="errorService.failure.emailGroup.To" value="[e-mail]" type="java.lang.String" override="false" /> <Environment name="errorService.failure.emailGroup.From" value="[e-mail]" type="java.lang.String" override="false" /> <!-- Delete Pre Dockets Pathway Request Email Configurations Starts --> <Environment name="deleteRequest.email.from" value="[e-mail]" type="java.lang.String" override="false" /> <Environment name="deleteRequest.emailGroup.To" value= "[e-mail],[e-mail]" type="java.lang.String" override="false" /> <Environment name="correctionHistory.emailGroup.CC" value="[e-mail]" type="java.lang.String" override="false" /> <!-- Delete Pre Dockets Pathway Request Email Configurations Ends --> <Environment name="critical.error.max.retry" value="5" type="java.lang.String" override="false" /> <Environment name="critical.error.delay" value="60" type="java.lang.String" override="false" /> <Environment name="docket.extract.queue.criteria" value="NOVUSCLTJMS" type="java.lang.String" override="false" /> <Environment name="docket.extract.retry" value="10" type="java.lang.String" override="false" /> <Environment name="docket.extract.delay" value="30" type="java.lang.String" override="false" /> <Environment name="knos.email.from" value="[e-mail]" type="java.lang.String" override="false" /> <Environment name="knos.email.to" value="[e-mail],[e-mail]" type="java.lang.String" override="false" /> <Environment name="predocket.queue.name" value="CONTECH.PREDOCKET.REQ.TEST" type="java.lang.String" override="false" /> <Environment name="predocket.queue.host.name" value="j3testmq.int.westgroup.com" type="java.lang.String" override="false" /> <Environment name="metadoc_retry_value" value="3" type="java.lang.String" override="false" /> <Environment name="metadoc_retry_sleep" value="15000" type="java.lang.String" override="false" /> <Environment name="metadoc_error_subject" value="ERROR Predocket Publisher: Metadoc not found for Extracted Docket" type="java.lang.String" override="false" /> <!-- Environment Variables --> <Environment name="Environment" value="test" type="java.lang.String" override="false"/> <Environment name="Version" value="1.0.0" type="java.lang.String" override="false"/> </Context>

It seems like test_context.xml is injected inside applicationcontext, do not know how.

depends on nthe type of environment dev_context, prod_context different context files are loaded to application context, can you please elaborate more how those two are lonked?

[Paul Clapham]

Aha! This is a Spring question. So let's put it in the Spring forum.