Does anyone require anything more from me to help diagnose this issue? Thanks...
thaibox1 wrote: > > I'm using MQ series 5.2 (I know it's old, but it's supposedly JMS > compliant). We're looking to move off Websphere MQ and I'm evaluating > ActiveMQ, but we're still going to need to hook it up to Websphere MQ > since most of our remote clients use that app for remote messaging. The > problem I'm facing is that I'm struggling to configure the JMS bridge to > successfully connect to Websphere MQ. Here is the activemq.xml file that > I'm using: > > <beans> > > <!-- Allows us to use system properties as variables in this > configuration file --> > <bean > class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> > > <broker xmlns="http://activemq.org/config/1.0"; > brokerName="ALERTQ" > useJmx="true" > persistent="true"> > > <!-- Use the following to set the broker memory limit --> > <memoryManager> > <usageManager id="memory-manager" limit="256 MB"/> > </memoryManager> > > <destinations> > <queue physicalName="US.TO.THEM" /> > <queue physicalName="THEM.TO.US" /> > <topic physicalName="ALERT.TOPIC" /> > </destinations> > > <transportConnectors> > <transportConnector name="openwire" uri="tcp://mqserver:31313" /> > <!-- discoveryUri="multicast://default" --> > </transportConnectors> > > <networkConnectors> > <!-- by default just auto discover the other brokers --> > <!-- <networkConnector name="default-nc" uri="multicast://default"/> > --> > </networkConnectors> > > <!-- Use the following to configure how ActiveMQ is exposed in JMX --> > <managementContext> > <managementContext connectorPort="5099" > jmxDomainName="org.apache.activemq"/> > </managementContext> > > <jmsBridgeConnectors> > <jmsQueueConnector > outboundQueueConnectionFactory="#remoteFactory"> > <inboundQueueBridges> > <inboundQueueBridge > inboundQueueName="THEM.TO.US" > > localQueueName="THEM.TO.US"/> > </inboundQueueBridges> > <outboundQueueBridges> > <outboundQueueBridge > outboundQueueName="US.TO.THEM" > > localQueueName="US.TO.THEM"/> > </outboundQueueBridges> > </jmsQueueConnector> > </jmsBridgeConnectors> > > <!-- In ActiveMQ 4, you can setup destination policies --> > <destinationPolicy> > <policyMap><policyEntries> > <policyEntry topic="ALERT.>"> > <dispatchPolicy> > <strictOrderDispatchPolicy /> > </dispatchPolicy> > <subscriptionRecoveryPolicy> > <lastImageSubscriptionRecoveryPolicy /> > </subscriptionRecoveryPolicy> > </policyEntry> > </policyEntries></policyMap> > </destinationPolicy> > > > <persistenceAdapter> > <journaledJDBC journalLogFiles="5" > dataDirectory="${activemq.base}/activemq-data"/> > </persistenceAdapter> > > </broker> > > <bean id="remoteFactory" > class="com.ibm.mq.jms.MQQueueConnectionFactory"> > <property name="transportType" value="1"/> > <property name="hostName" value="remoteIP"/> > <property name="port" value="1444"/> > <property name="queueManager" value="ALERTQ"/> > <property name="channel" value="US.TO.THEM"/> > </bean> > > When I start it up, I get: > > ./activemq > ACTIVEMQ_HOME: /u/pkgs/activemq/4.1.1 > ACTIVEMQ_BASE: /u/home/admin/work/activemq/build > Loading message broker from: xbean:activemq.xml > INFO CollectionFactory - JDK 1.4+ collections available > INFO XBeanXmlBeanDefinitionReader - Loading XML bean definitions from > class path resource [activemq.xml] > INFO ClassPathXmlApplicationContext - Bean factory for application > context > [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=14247437]: > org.springframework.beans.factory.support.DefaultListableBeanFactory > defining beans > [org.springframework.beans.factory.config.PropertyPlaceholderConfigurer,org.apache.activemq.xbean.XBeanBrokerService,remoteFactory]; > root of BeanFactory hierarchy > INFO ClassPathXmlApplicationContext - 3 beans defined in application > context > [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=14247437] > INFO ClassPathXmlApplicationContext - Unable to locate MessageSource with > name 'messageSource': using default > [EMAIL PROTECTED] > INFO ClassPathXmlApplicationContext - Unable to locate > ApplicationEventMulticaster with name 'applicationEventMulticaster': using > default > [EMAIL PROTECTED] > INFO DefaultListableBeanFactory - Pre-instantiating singletons in > factory > [org.springframework.beans.factory.support.DefaultListableBeanFactory > defining beans > [org.springframework.beans.factory.config.PropertyPlaceholderConfigurer,org.apache.activemq.xbean.XBeanBrokerService,remoteFactory]; > root of BeanFactory hierarchy] > INFO BrokerService - ActiveMQ 4.1.1 JMS Message Broker > (ALERTQ) is starting > INFO BrokerService - For help or more information please > see: http://incubator.apache.org/activemq/ > INFO JDBCPersistenceAdapter - Database driver recognized: > [apache_derby_embedded_jdbc_driver] > INFO DefaultDatabaseLocker - Attempting to acquire the exclusive > lock to become the Master broker > INFO DefaultDatabaseLocker - Becoming the master on dataSource: > [EMAIL PROTECTED] > INFO JournalPersistenceAdapter - Journal Recovery Started from: > Active Journal: using 5 x 20.0 Megs at: > /etrade/home/mrodrig9/work/activemq/build/activemq-data/journal > INFO JournalPersistenceAdapter - Journal Recovered: 0 message(s) in > transactions recovered. > INFO TransportServerThreadSupport - Listening for connections at: > tcp://someserver:31313 > INFO TransportConnector - Connector openwire Started > INFO ManagementContext - JMX consoles can connect to > service:jmx:rmi:///jndi/rmi://localhost:5099/jmxrmi > Unable to load message catalog - mqji > ERROR JmsQueueConnector - Failed to initialize the > JMSConnector > javax.jms.JMSException: MQJMS2005: failed to create MQQueueManager for > '10.52.92.78:ALERTQ' > at > com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:546) > at com.ibm.mq.jms.MQConnection.createQM(MQConnection.java:1137) > at > com.ibm.mq.jms.MQConnection.createQMNonXA(MQConnection.java:799) > at > com.ibm.mq.jms.MQQueueConnection.<init>(MQQueueConnection.java:255) > at > com.ibm.mq.jms.MQQueueConnection.<init>(MQQueueConnection.java:78) > at > com.ibm.mq.jms.MQQueueConnectionFactory.createQueueConnection(MQQueueConnectionFactory.java:142) > at > org.apache.activemq.network.jms.JmsQueueConnector.initializeForeignQueueConnection(JmsQueueConnector.java:216) > at > org.apache.activemq.network.jms.JmsQueueConnector.init(JmsQueueConnector.java:54) > at > org.apache.activemq.network.jms.JmsConnector.start(JmsConnector.java:114) > at > org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:1494) > at > org.apache.activemq.broker.BrokerService.start(BrokerService.java:402) > at > org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:47) > at > org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1062) > at > org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1029) > at > org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:420) > at > org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:245) > at > org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:141) > at > org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:242) > at > org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:156) > at > org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:290) > at > org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:348) > at > org.apache.xbean.spring.context.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:161) > at > org.apache.xbean.spring.context.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:51) > at > org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:41) > at > org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:57) > at > org.apache.activemq.console.command.StartCommand.startBroker(StartCommand.java:82) > at > org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:47) > at > org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:50) > at > org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:82) > at > org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:50) > at > org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:46) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > at java.lang.reflect.Method.invoke(Method.java:585) > at org.apache.activemq.console.Main.runTaskClass(Main.java:202) > at org.apache.activemq.console.Main.main(Main.java:91) > INFO JmsConnector - JMS Connector Connector:0 Started > INFO BrokerService - ActiveMQ JMS Message Broker > (ALERTQ, ID:dev6m3-53031-1190315038649-1:0) started > ERROR TransportConnector - Could not accept connection from > /remoteIP:52978: java.io.IOException: Wire format negociation timeout: > peer did not send his wire format. > java.io.IOException: Wire format negociation timeout: peer did not send > his wire format. > at > org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:88) > at > org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47) > at > org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1138) > at > org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:805) > at > org.apache.activemq.broker.TransportConnection.start(TransportConnection.java:885) > at > org.apache.activemq.broker.TransportConnector$1.onAccept(TransportConnector.java:148) > at > org.apache.activemq.transport.tcp.TcpTransportServer.run(TcpTransportServer.java:167) > at java.lang.Thread.run(Thread.java:595) > > So here we see that activemq tries to connect to websphere MQ and fails > miserably and then every so often, WebsphereMQ tries to connect to > Activemq and falls down as well. > > Any help you can offer would be greatly appreciated. > -- View this message in context: http://www.nabble.com/ActiveMQ-JMS-Bridge-to-Websphere-MQ-tf4489485s2354.html#a12865475 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
