You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by Jamie Le Grange <ja...@googlemail.com> on 2006/02/20 17:46:31 UTC
jsr181 and clustering
hi,
servicemix does a great job of allowing components to talk to each
other across a cluster. i have a problem with the jsr181 component,
however, in that the JbiProxy doesn't seem to be able to look up an
endpoint in another node in the cluster to bind to it.
when the JbiProxy and the jsr181 endpoint are in the same container
they work fine.
should it be working across the cluster (i.e. is it me being an idiot)
or am i expecting too much at this stage?
thanks
Re: jsr181 and clustering
Posted by Jamie Le Grange <ja...@googlemail.com>.
done:
http://jira.activemq.org/jira/browse/SM-322
On 20/02/06, Guillaume Nodet <gu...@worldonline.fr> wrote:
> The problem is that the endpoint descriptors (wsdl) can not be accessed
> for remote endpoints in a cluster.
> That's the reason why you have an NPE.
> Could you please raise a jira issue ?
>
> Cheers,
> Guillaume Nodet
>
> Jamie Le Grange wrote:
>
> >haha,
> >
> >okay, in this case I am an idiot. I wasn't running the broker and I
> >just copied the stacktrace blindly. The real exception is:
> >
> >java.lang.NullPointerException
> > at org.apache.servicemix.jbi.framework.EndpointRegistry.getEndpointDescriptor(EndpointRegistry.java:197)
> > at org.apache.servicemix.jbi.framework.Registry.getEndpointDescriptor(Registry.java:203)
> > at org.apache.servicemix.jbi.framework.ComponentContextImpl.getEndpointDescriptor(ComponentContextImpl.java:379)
> > at org.apache.servicemix.jsr181.xfire.JbiProxy.chooseEndpoint(JbiProxy.java:135)
> > at org.apache.servicemix.jsr181.xfire.JbiProxy.getDescription(JbiProxy.java:100)
> > at org.apache.servicemix.jsr181.xfire.JbiProxy.getProxy(JbiProxy.java:78)
> > at org.apache.servicemix.jsr181.xfire.JbiProxy.create(JbiProxy.java:49)
> > at org.random.RandomClientTest.test(RandomClientTest.java:47)
> > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> > at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> > at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> > at java.lang.reflect.Method.invoke(Unknown Source)
> > at junit.framework.TestCase.runTest(TestCase.java:154)
> > at junit.framework.TestCase.runBare(TestCase.java:127)
> > at junit.framework.TestResult$1.protect(TestResult.java:106)
> > at junit.framework.TestResult.runProtected(TestResult.java:124)
> > at junit.framework.TestResult.run(TestResult.java:109)
> > at junit.framework.TestCase.run(TestCase.java:118)
> > at junit.framework.TestSuite.runTest(TestSuite.java:208)
> > at junit.framework.TestSuite.run(TestSuite.java:203)
> > at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
> > at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
> > at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
> >
> >
> >
> >On 20/02/06, Jamie Le Grange <ja...@googlemail.com> wrote:
> >
> >
> >>hiya,
> >>
> >>here follows a _relatively_ simple test. files are attached. please
> >>let me know if they don't get through the mailing list. They should
> >>be:
> >>
> >>IRandomService.java
> >>RandomClientTest.java
> >>RandomServer.java
> >>RandomService.java
> >>spring.xml
> >>
> >>NOTE: it expects an activemq broker running on tcp://localhost:61616
> >>and a whole bunch of jar files :)
> >>
> >>Instructions: Run "RandomServer" as a java application. Then run
> >>RandomClientTest as a testcase.
> >>
> >>exception is:
> >>
> >>javax.jbi.JBIException: javax.jms.JMSException: Could not connect to
> >>broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
> >>Connection refused: connect
> >> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:209)
> >> at org.apache.servicemix.jbi.nmr.Broker.init(Broker.java:126)
> >> at org.apache.servicemix.jbi.container.JBIContainer.init(JBIContainer.java:420)
> >> at org.random.RandomClientTest.test(RandomClientTest.java:41)
> >> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> >> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> >> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> >> at java.lang.reflect.Method.invoke(Unknown Source)
> >> at junit.framework.TestCase.runTest(TestCase.java:154)
> >> at junit.framework.TestCase.runBare(TestCase.java:127)
> >> at junit.framework.TestResult$1.protect(TestResult.java:106)
> >> at junit.framework.TestResult.runProtected(TestResult.java:124)
> >> at junit.framework.TestResult.run(TestResult.java:109)
> >> at junit.framework.TestCase.run(TestCase.java:118)
> >> at junit.framework.TestSuite.runTest(TestSuite.java:208)
> >> at junit.framework.TestSuite.run(TestSuite.java:203)
> >> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
> >> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
> >> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
> >>Caused by: javax.jms.JMSException: Could not connect to broker URL:
> >>tcp://localhost:61616. Reason: java.net.ConnectException: Connection
> >>refused: connect
> >> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:32)
> >> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:227)
> >> at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:139)
> >> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:193)
> >> ... 18 more
> >>Caused by: java.net.ConnectException: Connection refused: connect
> >> at java.net.PlainSocketImpl.socketConnect(Native Method)
> >> at java.net.PlainSocketImpl.doConnect(Unknown Source)
> >> at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
> >> at java.net.PlainSocketImpl.connect(Unknown Source)
> >> at java.net.SocksSocketImpl.connect(Unknown Source)
> >> at java.net.Socket.connect(Unknown Source)
> >> at java.net.Socket.connect(Unknown Source)
> >> at org.apache.activemq.transport.tcp.TcpTransport.createSocket(TcpTransport.java:203)
> >> at org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java:78)
> >> at org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(TcpTransportFactory.java:94)
> >> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:115)
> >> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:42)
> >> at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:76)
> >> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:199)
> >> ... 20 more
> >>
> >>
> >>
> >>On 20/02/06, Guillaume Nodet <gu...@worldonline.fr> wrote:
> >>
> >>
> >>>Hi Jamie !
> >>>
> >>>First, you're certainly not an idiot if you have succeeded in getting
> >>>the jsr181 component
> >>>to run, given the great amount of doc on it :)
> >>>I do not see any reason why it should not work. However I have never
> >>>tried it, so
> >>>there may some bugs.
> >>>
> >>>Could you describe your environment ? or send a simple test if you have
> >>>one ?
> >>>
> >>>Cheers,
> >>>Guillaume Nodet
> >>>
> >>>Jamie Le Grange wrote:
> >>>
> >>>
> >>>
> >>>>hi,
> >>>>
> >>>>servicemix does a great job of allowing components to talk to each
> >>>>other across a cluster. i have a problem with the jsr181 component,
> >>>>however, in that the JbiProxy doesn't seem to be able to look up an
> >>>>endpoint in another node in the cluster to bind to it.
> >>>>
> >>>>when the JbiProxy and the jsr181 endpoint are in the same container
> >>>>they work fine.
> >>>>
> >>>>should it be working across the cluster (i.e. is it me being an idiot)
> >>>>or am i expecting too much at this stage?
> >>>>
> >>>>thanks
> >>>>
> >>>>
> >>>>
> >>>>
> >>>>
> >>>>
> >>
> >>
> >>
> >
> >
> >
> >
>
Re: jsr181 and clustering
Posted by Guillaume Nodet <gu...@worldonline.fr>.
The problem is that the endpoint descriptors (wsdl) can not be accessed
for remote endpoints in a cluster.
That's the reason why you have an NPE.
Could you please raise a jira issue ?
Cheers,
Guillaume Nodet
Jamie Le Grange wrote:
>haha,
>
>okay, in this case I am an idiot. I wasn't running the broker and I
>just copied the stacktrace blindly. The real exception is:
>
>java.lang.NullPointerException
> at org.apache.servicemix.jbi.framework.EndpointRegistry.getEndpointDescriptor(EndpointRegistry.java:197)
> at org.apache.servicemix.jbi.framework.Registry.getEndpointDescriptor(Registry.java:203)
> at org.apache.servicemix.jbi.framework.ComponentContextImpl.getEndpointDescriptor(ComponentContextImpl.java:379)
> at org.apache.servicemix.jsr181.xfire.JbiProxy.chooseEndpoint(JbiProxy.java:135)
> at org.apache.servicemix.jsr181.xfire.JbiProxy.getDescription(JbiProxy.java:100)
> at org.apache.servicemix.jsr181.xfire.JbiProxy.getProxy(JbiProxy.java:78)
> at org.apache.servicemix.jsr181.xfire.JbiProxy.create(JbiProxy.java:49)
> at org.random.RandomClientTest.test(RandomClientTest.java:47)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> at java.lang.reflect.Method.invoke(Unknown Source)
> at junit.framework.TestCase.runTest(TestCase.java:154)
> at junit.framework.TestCase.runBare(TestCase.java:127)
> at junit.framework.TestResult$1.protect(TestResult.java:106)
> at junit.framework.TestResult.runProtected(TestResult.java:124)
> at junit.framework.TestResult.run(TestResult.java:109)
> at junit.framework.TestCase.run(TestCase.java:118)
> at junit.framework.TestSuite.runTest(TestSuite.java:208)
> at junit.framework.TestSuite.run(TestSuite.java:203)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
>
>
>
>On 20/02/06, Jamie Le Grange <ja...@googlemail.com> wrote:
>
>
>>hiya,
>>
>>here follows a _relatively_ simple test. files are attached. please
>>let me know if they don't get through the mailing list. They should
>>be:
>>
>>IRandomService.java
>>RandomClientTest.java
>>RandomServer.java
>>RandomService.java
>>spring.xml
>>
>>NOTE: it expects an activemq broker running on tcp://localhost:61616
>>and a whole bunch of jar files :)
>>
>>Instructions: Run "RandomServer" as a java application. Then run
>>RandomClientTest as a testcase.
>>
>>exception is:
>>
>>javax.jbi.JBIException: javax.jms.JMSException: Could not connect to
>>broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
>>Connection refused: connect
>> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:209)
>> at org.apache.servicemix.jbi.nmr.Broker.init(Broker.java:126)
>> at org.apache.servicemix.jbi.container.JBIContainer.init(JBIContainer.java:420)
>> at org.random.RandomClientTest.test(RandomClientTest.java:41)
>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
>> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>> at java.lang.reflect.Method.invoke(Unknown Source)
>> at junit.framework.TestCase.runTest(TestCase.java:154)
>> at junit.framework.TestCase.runBare(TestCase.java:127)
>> at junit.framework.TestResult$1.protect(TestResult.java:106)
>> at junit.framework.TestResult.runProtected(TestResult.java:124)
>> at junit.framework.TestResult.run(TestResult.java:109)
>> at junit.framework.TestCase.run(TestCase.java:118)
>> at junit.framework.TestSuite.runTest(TestSuite.java:208)
>> at junit.framework.TestSuite.run(TestSuite.java:203)
>> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
>> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
>> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
>>Caused by: javax.jms.JMSException: Could not connect to broker URL:
>>tcp://localhost:61616. Reason: java.net.ConnectException: Connection
>>refused: connect
>> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:32)
>> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:227)
>> at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:139)
>> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:193)
>> ... 18 more
>>Caused by: java.net.ConnectException: Connection refused: connect
>> at java.net.PlainSocketImpl.socketConnect(Native Method)
>> at java.net.PlainSocketImpl.doConnect(Unknown Source)
>> at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
>> at java.net.PlainSocketImpl.connect(Unknown Source)
>> at java.net.SocksSocketImpl.connect(Unknown Source)
>> at java.net.Socket.connect(Unknown Source)
>> at java.net.Socket.connect(Unknown Source)
>> at org.apache.activemq.transport.tcp.TcpTransport.createSocket(TcpTransport.java:203)
>> at org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java:78)
>> at org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(TcpTransportFactory.java:94)
>> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:115)
>> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:42)
>> at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:76)
>> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:199)
>> ... 20 more
>>
>>
>>
>>On 20/02/06, Guillaume Nodet <gu...@worldonline.fr> wrote:
>>
>>
>>>Hi Jamie !
>>>
>>>First, you're certainly not an idiot if you have succeeded in getting
>>>the jsr181 component
>>>to run, given the great amount of doc on it :)
>>>I do not see any reason why it should not work. However I have never
>>>tried it, so
>>>there may some bugs.
>>>
>>>Could you describe your environment ? or send a simple test if you have
>>>one ?
>>>
>>>Cheers,
>>>Guillaume Nodet
>>>
>>>Jamie Le Grange wrote:
>>>
>>>
>>>
>>>>hi,
>>>>
>>>>servicemix does a great job of allowing components to talk to each
>>>>other across a cluster. i have a problem with the jsr181 component,
>>>>however, in that the JbiProxy doesn't seem to be able to look up an
>>>>endpoint in another node in the cluster to bind to it.
>>>>
>>>>when the JbiProxy and the jsr181 endpoint are in the same container
>>>>they work fine.
>>>>
>>>>should it be working across the cluster (i.e. is it me being an idiot)
>>>>or am i expecting too much at this stage?
>>>>
>>>>thanks
>>>>
>>>>
>>>>
>>>>
>>>>
>>>>
>>
>>
>>
>
>
>
>
Re: jsr181 and clustering
Posted by Jamie Le Grange <ja...@googlemail.com>.
haha,
okay, in this case I am an idiot. I wasn't running the broker and I
just copied the stacktrace blindly. The real exception is:
java.lang.NullPointerException
at org.apache.servicemix.jbi.framework.EndpointRegistry.getEndpointDescriptor(EndpointRegistry.java:197)
at org.apache.servicemix.jbi.framework.Registry.getEndpointDescriptor(Registry.java:203)
at org.apache.servicemix.jbi.framework.ComponentContextImpl.getEndpointDescriptor(ComponentContextImpl.java:379)
at org.apache.servicemix.jsr181.xfire.JbiProxy.chooseEndpoint(JbiProxy.java:135)
at org.apache.servicemix.jsr181.xfire.JbiProxy.getDescription(JbiProxy.java:100)
at org.apache.servicemix.jsr181.xfire.JbiProxy.getProxy(JbiProxy.java:78)
at org.apache.servicemix.jsr181.xfire.JbiProxy.create(JbiProxy.java:49)
at org.random.RandomClientTest.test(RandomClientTest.java:47)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at junit.framework.TestCase.runTest(TestCase.java:154)
at junit.framework.TestCase.runBare(TestCase.java:127)
at junit.framework.TestResult$1.protect(TestResult.java:106)
at junit.framework.TestResult.runProtected(TestResult.java:124)
at junit.framework.TestResult.run(TestResult.java:109)
at junit.framework.TestCase.run(TestCase.java:118)
at junit.framework.TestSuite.runTest(TestSuite.java:208)
at junit.framework.TestSuite.run(TestSuite.java:203)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
On 20/02/06, Jamie Le Grange <ja...@googlemail.com> wrote:
> hiya,
>
> here follows a _relatively_ simple test. files are attached. please
> let me know if they don't get through the mailing list. They should
> be:
>
> IRandomService.java
> RandomClientTest.java
> RandomServer.java
> RandomService.java
> spring.xml
>
> NOTE: it expects an activemq broker running on tcp://localhost:61616
> and a whole bunch of jar files :)
>
> Instructions: Run "RandomServer" as a java application. Then run
> RandomClientTest as a testcase.
>
> exception is:
>
> javax.jbi.JBIException: javax.jms.JMSException: Could not connect to
> broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
> Connection refused: connect
> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:209)
> at org.apache.servicemix.jbi.nmr.Broker.init(Broker.java:126)
> at org.apache.servicemix.jbi.container.JBIContainer.init(JBIContainer.java:420)
> at org.random.RandomClientTest.test(RandomClientTest.java:41)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> at java.lang.reflect.Method.invoke(Unknown Source)
> at junit.framework.TestCase.runTest(TestCase.java:154)
> at junit.framework.TestCase.runBare(TestCase.java:127)
> at junit.framework.TestResult$1.protect(TestResult.java:106)
> at junit.framework.TestResult.runProtected(TestResult.java:124)
> at junit.framework.TestResult.run(TestResult.java:109)
> at junit.framework.TestCase.run(TestCase.java:118)
> at junit.framework.TestSuite.runTest(TestSuite.java:208)
> at junit.framework.TestSuite.run(TestSuite.java:203)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
> Caused by: javax.jms.JMSException: Could not connect to broker URL:
> tcp://localhost:61616. Reason: java.net.ConnectException: Connection
> refused: connect
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:32)
> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:227)
> at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:139)
> at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:193)
> ... 18 more
> Caused by: java.net.ConnectException: Connection refused: connect
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at java.net.PlainSocketImpl.doConnect(Unknown Source)
> at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
> at java.net.PlainSocketImpl.connect(Unknown Source)
> at java.net.SocksSocketImpl.connect(Unknown Source)
> at java.net.Socket.connect(Unknown Source)
> at java.net.Socket.connect(Unknown Source)
> at org.apache.activemq.transport.tcp.TcpTransport.createSocket(TcpTransport.java:203)
> at org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java:78)
> at org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(TcpTransportFactory.java:94)
> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:115)
> at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:42)
> at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:76)
> at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:199)
> ... 20 more
>
>
>
> On 20/02/06, Guillaume Nodet <gu...@worldonline.fr> wrote:
> > Hi Jamie !
> >
> > First, you're certainly not an idiot if you have succeeded in getting
> > the jsr181 component
> > to run, given the great amount of doc on it :)
> > I do not see any reason why it should not work. However I have never
> > tried it, so
> > there may some bugs.
> >
> > Could you describe your environment ? or send a simple test if you have
> > one ?
> >
> > Cheers,
> > Guillaume Nodet
> >
> > Jamie Le Grange wrote:
> >
> > >hi,
> > >
> > >servicemix does a great job of allowing components to talk to each
> > >other across a cluster. i have a problem with the jsr181 component,
> > >however, in that the JbiProxy doesn't seem to be able to look up an
> > >endpoint in another node in the cluster to bind to it.
> > >
> > >when the JbiProxy and the jsr181 endpoint are in the same container
> > >they work fine.
> > >
> > >should it be working across the cluster (i.e. is it me being an idiot)
> > >or am i expecting too much at this stage?
> > >
> > >thanks
> > >
> > >
> > >
> > >
> >
>
>
>
Re: jsr181 and clustering
Posted by Jamie Le Grange <ja...@googlemail.com>.
hiya,
here follows a _relatively_ simple test. files are attached. please
let me know if they don't get through the mailing list. They should
be:
IRandomService.java
RandomClientTest.java
RandomServer.java
RandomService.java
spring.xml
NOTE: it expects an activemq broker running on tcp://localhost:61616
and a whole bunch of jar files :)
Instructions: Run "RandomServer" as a java application. Then run
RandomClientTest as a testcase.
exception is:
javax.jbi.JBIException: javax.jms.JMSException: Could not connect to
broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
Connection refused: connect
at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:209)
at org.apache.servicemix.jbi.nmr.Broker.init(Broker.java:126)
at org.apache.servicemix.jbi.container.JBIContainer.init(JBIContainer.java:420)
at org.random.RandomClientTest.test(RandomClientTest.java:41)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at junit.framework.TestCase.runTest(TestCase.java:154)
at junit.framework.TestCase.runBare(TestCase.java:127)
at junit.framework.TestResult$1.protect(TestResult.java:106)
at junit.framework.TestResult.runProtected(TestResult.java:124)
at junit.framework.TestResult.run(TestResult.java:109)
at junit.framework.TestCase.run(TestCase.java:118)
at junit.framework.TestSuite.runTest(TestSuite.java:208)
at junit.framework.TestSuite.run(TestSuite.java:203)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
Caused by: javax.jms.JMSException: Could not connect to broker URL:
tcp://localhost:61616. Reason: java.net.ConnectException: Connection
refused: connect
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:32)
at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:227)
at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:139)
at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.init(JMSFlow.java:193)
... 18 more
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.PlainSocketImpl.doConnect(Unknown Source)
at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at org.apache.activemq.transport.tcp.TcpTransport.createSocket(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java:78)
at org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(TcpTransportFactory.java:94)
at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:115)
at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:42)
at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:76)
at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:199)
... 20 more
On 20/02/06, Guillaume Nodet <gu...@worldonline.fr> wrote:
> Hi Jamie !
>
> First, you're certainly not an idiot if you have succeeded in getting
> the jsr181 component
> to run, given the great amount of doc on it :)
> I do not see any reason why it should not work. However I have never
> tried it, so
> there may some bugs.
>
> Could you describe your environment ? or send a simple test if you have
> one ?
>
> Cheers,
> Guillaume Nodet
>
> Jamie Le Grange wrote:
>
> >hi,
> >
> >servicemix does a great job of allowing components to talk to each
> >other across a cluster. i have a problem with the jsr181 component,
> >however, in that the JbiProxy doesn't seem to be able to look up an
> >endpoint in another node in the cluster to bind to it.
> >
> >when the JbiProxy and the jsr181 endpoint are in the same container
> >they work fine.
> >
> >should it be working across the cluster (i.e. is it me being an idiot)
> >or am i expecting too much at this stage?
> >
> >thanks
> >
> >
> >
> >
>
Re: jsr181 and clustering
Posted by Guillaume Nodet <gu...@worldonline.fr>.
Hi Jamie !
First, you're certainly not an idiot if you have succeeded in getting
the jsr181 component
to run, given the great amount of doc on it :)
I do not see any reason why it should not work. However I have never
tried it, so
there may some bugs.
Could you describe your environment ? or send a simple test if you have
one ?
Cheers,
Guillaume Nodet
Jamie Le Grange wrote:
>hi,
>
>servicemix does a great job of allowing components to talk to each
>other across a cluster. i have a problem with the jsr181 component,
>however, in that the JbiProxy doesn't seem to be able to look up an
>endpoint in another node in the cluster to bind to it.
>
>when the JbiProxy and the jsr181 endpoint are in the same container
>they work fine.
>
>should it be working across the cluster (i.e. is it me being an idiot)
>or am i expecting too much at this stage?
>
>thanks
>
>
>
>