国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

<!-- ////////////////////////////////////////// -->
<!-- For JMS (ActiveMQ) Begin -->
<!-- ////////////////////////////////////////// -->
<bean id="broker"
class="org.apache.activemq.xbean.BrokerFactoryBean">
<property name="config" value="classpath:activemq.xml" />
<property name="start" value="true" />
</bean>

<bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory"
depends-on="broker">
<property name="brokerURL" value="vm://billing" />
</bean>

<!--<amq:connectionFactory id="jmsConnectionFactory" brokerURL="vm://localhost"/>-->

<bean id="jmsFactoryPool"
class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

<bean id="jmsTransactionManager"
class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

<bean id="messageConverter"
class="org.springframework.jms.support.converter.SimpleMessageConverter" />

<bean id="jmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactoryPool" />
<property name="messageConverter" ref="messageConverter" />
</bean>

<!-- ActiveMQ destinations to use -->
<amq:queue name="mBSettlementQueue"

physicalName="pp.queue.MBSettlementQueue" />

<!-- POJO which send success message by JmsTemplate and queue -->
<bean id="settlementMsgProducer"
class="com.pp.billing.settlement.SettlementMsgProducer">
<property name="jmsTemplate" ref="jmsTemplate" />
<property name="destination" ref="mBSettlementQueue" />
</bean>

<bean id="settlementMsgListener"
class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg>
<bean
class="com.PP.billing.settlement.SettlementMsgListener">
</bean>
</constructor-arg>
<!-- may be other method -->
<property name="defaultListenerMethod" value="onMessage" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="messageConverter" />
</bean>

<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<!-- property name="transactionManager" ref="jmsTransactionManager" / -->

  <property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="mBSettlementQueue" />
<property name="messageListener" ref="settlementMsgListener" />
<property name="concurrentConsumers" value="2" />
<property name="recoveryInterval" value="3000" />
<property name="receiveTimeout" value="10000" />
</bean>

public class SoapGWProducer {	/**	 *define log object to print log record	 */	private static Log log = LogFactory.getLog(SoapGWProducer.class);	/**	 *define jmsTemplate	 */	private JmsTemplate jmsTemplate;	/**	 *define destination	 */	private Queue destination;	/**	 * @return Returns jmsTemplate.	 */	public JmsTemplate getJmsTemplate() {		return jmsTemplate;	}	/**	 * @param jmsTemplate The jmsTemplate to set.	 */	public void setJmsTemplate(JmsTemplate jmsTemplate) {		this.jmsTemplate = jmsTemplate;	}	/**	 * @return destination	 */	public Queue getDestination() {		return destination;	}	/**	 * @param destination destination	 */	public void setDestination(Queue destination) {		this.destination = destination;	}	/**	 * send message to queue	 * @param message message	 */	public void send(SoapGWMessage message) {		try {			jmsTemplate.convertAndSend(this.destination, message);		} catch (Exception e) {			log.error("send SoapGWMessage to SoapGWQueue error:"					+ e.getMessage(), e);		}	}}

public class SoapGWListener {	/**	 *define log object to print the log content	 */	private static Log log = LogFactory.getLog(SoapGWListener.class);	/**	 *define start message content	 */	public static final String START_MESSAGE = "Start";	/**	 * listerner message and do mblox SoapGWMessage	 * @param message message	 */	public void onMessage(SoapGWMessage message) {		if (log.isInfoEnabled()) {			log.info("start SoapGWListener onMessage(),parameter is:" + message);		}		//get message informatio		String phoneNumber = message.getPhoneNumber();	}

activemq.xml

<?xml version="1.0" encoding="ISO-8859-1"?><beans>    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>    <broker xmlns="http://activemq.org/config/1.0" brokerName="localhost">    <persistenceAdapter>        <jdbcPersistenceAdapter dataSource="#mssql-ds" useDatabaseLock="false">            <statements>                <statements binaryDataType ="binary(1024)"/>            </statements>         </jdbcPersistenceAdapter>    </persistenceAdapter>      <!-- Use the following to configure how ActiveMQ is exposed in JMX -->      <managementContext>         <managementContext connectorPort="1099" jmxDomainName="org.apache.activemq"/>      </managementContext>    </broker>    <bean id="mssql-ds" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">      <property name="driverClass" value="$DB_DRIVERNAME"/>      <property name="jdbcUrl" value="$DB_QUEUE_URL"/>      <property name="user" value="$DB_QUEUE_USER"/>      <property name="password" value="$DB_QUEUE_PASSWD"/>      <property name="initialPoolSize" value="50"/>      <property name="minPoolSize" value="20"/>      <property name="maxPoolSize" value="1000"/>      <property name="acquireIncrement" value="30"/>      <property name="maxIdleTime" value="100"/>      <property name="maxStatements" value="10"/>    </bean></beans>