Hello all,

I'm still a newbie to Servicemix. I am trying to make the JMS component work
and have a JMS client send message to it. But I always get the following
errors when I execute my JMS client:

--------------------------------------------------------------------
Exception in thread "main" java.lang.NoSuchMethodError:
org.apache.activemq.command.ConnectionInfo.isClientMaster()Z
        at
org.apache.activemq.openwire.v2.ConnectionInfoMarshaller.tightMarshal1(ConnectionInfoMarshaller.java:107)
        at
org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:234)
        at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:124)
        at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
        at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:78)
        at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:77)
        at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:68)
        at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:73)
        at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1131)
        at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1219)
        at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:272)
        at com.abacus.rtdemo.rtdemoclient.JMSClient.main(JMSClient.java:46)
Exception in thread "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616"
java.lang.AbstractMethodError:
org.apache.activemq.openwire.v2.BrokerInfoMarshaller.tightUnmarshal(Lorg/apache/activemq/openwire/OpenWireFormat;Ljava/lang/Object;Ljava/io/DataInputStream;Lorg/apache/activemq/openwire/BooleanStream;)V
        at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:350)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:276)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
        at java.lang.Thread.run(Thread.java:619)
--------------------------------------------------------------------

I installed the Servicemix-JMS component and deploy the following
configuration:
--------------------------------------------------------------------
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:sm="http://servicemix.apache.org/config/1.0";
        xmlns:jms="http://servicemix.apache.org/jms/1.0";
        xmlns:rtdemo="http://rtdemo.abacus.com/rtdemo";>
        <!-- JMS POLLER - CONSUMER -->
        <jms:endpoint service="rtdemo:MyConsumer" endpoint="MyConsumer"
                targetService="rtdemo:MyProvider" targetEndpoint="MyProvider"
                role="consumer" 
defaultMep="http://www.w3.org/2004/08/wsdl/in-out";
                destinationStyle="topic"
                jmsProviderDestinationName="demo.org.servicemix.source"
                connectionFactory="#connectionFactory" />
        <!-- JMS SENDER - PROVIDER -->
        <jms:endpoint service="rtdemo:MyProvider" endpoint="myProvider"
                role="provider" 
defaultMep="http://www.w3.org/2004/08/wsdl/in-out";
                destinationStyle="topic"
                jmsProviderDestinationName="demo.org.servicemix.result"
                connectionFactory="#connectionFactory" />
        <!-- FACTORY BEAN -->
        <bean id="connectionFactory"
                class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="brokerURL" value="tcp://localhost:61616" />
        </bean>
</beans>
--------------------------------------------------------------------

Then my JMS client code is like:

ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory("tcp://localhost:61616");
ActiveMQTopic pubTopic = new ActiveMQTopic("demo.org.servicemix.source");
ActiveMQTopic subTopic = new ActiveMQTopic("demo.org.servicemix.result");
        
Connection connection = factory.createConnection();
//here is where the exception is raised
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
...

It seems the connection cannot be set up. Could any of you give me some
hints on how to solve the problem? Thanks a lot!!
-- 
View this message in context: 
http://www.nabble.com/JMS-Binding-Problem-tf4032760s12049.html#a11456056
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Reply via email to