Hello Claus, Guillaume, Ioannis and Christian, Thanks guys, your response times were truly impressive (you're all a genuine credit to Apache and your respective companies). When I returned to it, my issue was quickly resolved thanks to your advice =)
One thing I found is that the actual resolution is to hostname and not IP (which makes sense given cloud environments), I hadn't set these machines up properly (so their names only worked locally). Don't seem to be able to create an account on Fusesource's Jira, so can't add this as a comment to FABRIC-266. Best regards, Caspar On 25 September 2012 07:13, Claus Ibsen <claus.ib...@gmail.com> wrote: > Hi > > This issue was also discussed recently at the Fuse Forums > http://fusesource.com/forums/thread.jspa?threadID=4262&tstart=0 > > Where the solution was posted as well, eg to change localhost to the ip > address. > We have logged a ticket to get the example improved for a future release. > > > > On Mon, Sep 24, 2012 at 5:40 PM, Caspar MacRae <ear...@gmail.com> wrote: > > > > Hello, > > > > I'm looking to move our distributed services (currently using Camel's JMS > > remoting) to a dOSGi solution. I won't be looking at ECF (simply because > > they don't seem to publish up-to-date maven artifacts), so that leaves > Fuse > > Fabric and Karaf Cellar. > > > > Apologies for the length of this mail, what follows is a log of the > steps I > > took with Fabric, in the hope that somebody can spot something. > > > > Thought I'd try to get something working in FuseESB before porting in > back > > to Karaf 2.2.x. > > > > So far I've burnt a bit of time with Fabric but not made any progress > (tried > > trunk and fuse-fabric-7.0.0.fuse-061, currently looking at > > fuse-fabric-7.0.1.fuse-084). I suspect I'm doing something stupid or > have > > missed something vital out. > > > > Starting with the simplest distributed case I've got a features.xml and 3 > > simple bundles; a service interface bundle, a client bundle and a service > > implementation bundle. I've ensured the client and service work in a > single > > instance, but am a bit stumped as to how to get this running over fabric. > > > > The service imp exports the property "service.exported.interfaces" as "*" > > and the interface implied by the asterisk is available to both service > imp > > and client bundles (i.e. deployed to both instances). > > > > On both boxes I've temporarily instructed iptables to open all ports and > I'm > > running the fusefabric command as root. > > > > > > # On box1 (provider): > > > > tar -xzf /data/share/fuse-fabric-7.0.1.fuse-084.tar.gz > > cd fuse-fabric-7.0.1.fuse-084/ > > sudo ./bin/fusefabric > > > > > > # On box1's Karaf shell: > > > > log:set TRACE net.earcam > > log:set TRACE org.fusesource.fabric.dosgi > > features:install fabric-commands fabric-dosgi fabric-configadmin > > fabric-zookeeper-commands > > # Line above logs exception as Zookeeper not created or ensembled - > assuming > > safe to ignore > > > > fabric:create --clean root # Causes exception 1 (see below), again > > assuming this is safe to ignore > > > > fabric:profile-create --parents dosgi dosgi-provider > > fabric:profile-edit --repositories > > > mvn:net.earcam.example.hello/net.earcam.example.hello.feature/0.0.1-SNAPSHOT/xml/features > > dosgi-provider > > fabric:profile-edit --features hello-server dosgi-provider > > > > fabric:container-create --profile dosgi-provider --parent root > > dosgi-provider > > > > fabric:container-list # Shows success > > > > fabric:container-connect dosgi-provider # Connects fine, can see > > ..example.hello bundles installed > > log:set TRACE net.earcam > > log:set TRACE org.fusesource.fabric.dosgi > > > > > > # ------ > > > > # On box2 (consumer): > > > > tar -xzf /data/share/fuse-fabric-7.0.1.fuse-084.tar.gz > > cd fuse-fabric-7.0.1.fuse-084/ > > sed -i s/karaf.name=root/karaf.name=vm-mint1/ etc/system.properties > > sudo ./bin/fusefabric > > > > # On box2's Karaf shell: > > > > log:set TRACE net.earcam > > log:set TRACE org.fusesource.fabric.dosgi > > features:install fabric-commands fabric-dosgi fabric-configadmin > > fabric-zookeeper-commands > > > > fabric:join 10.39.216.49 # The IP of box1 > > > > fabric:profile-create --parents dosgi dosgi-consumer > > fabric:profile-edit --repositories > > > mvn:net.earcam.example.hello/net.earcam.example.hello.feature/0.0.1-SNAPSHOT/xml/features > > dosgi-consumer > > fabric:profile-edit --features hello-client dosgi-consumer > > > > fabric:container-create --profile dosgi-consumer --parent vm-mint1 > > dosgi-consumer > > > > fabric:container-list # Shows success > > > > fabric:container-connect dosgi-consumer # Connects fine, can see > > ..example.hello bundles installed > > log:set TRACE net.earcam > > log:set TRACE org.fusesource.fabric.dosgi > > > > > > > > # ------ > > > > The "provision status" is "success" for all when running container-list > and > > I can connect to the two new containers dosgi-provider and > dosgi-consumer. > > > > On box2, in the dosgi-consumer container, I can see the remote service > > exported from box1, and it disappears/appears as I stop/start the > exporting > > service bundle on box1. > > > > The imported service has "correct looking" properties: > > component.id = 2 > > component.name = net.earcam.example.hello.server.HelloService > > endpoint.framework.uuid = b5806ad9-7849-4aaf-adf7-56ba1e6538e3 > > endpoint.id = 2008920412-47095-1348493938958-0-3 > > fabric.address = tcp://localhost:44462 > > objectClass = net.earcam.example.hello.api.GreetingService > > service.id = 246 > > service.imported = true > > service.imported.configs = fabric-dosgi > > service.pid = net.earcam.example.hello.server.HelloService > > > > > > > > # Exception 1, seen on both boxes: > > > > java.lang.NullPointerException > > at org.fusesource.fabric.dosgi.impl.Manager.destroy(Manager.java:175) > > at org.fusesource.fabric.dosgi.Activator.destroy(Activator.java:46) > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > > Method)[:1.6.0_33] > > at > > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)[:1.6.0_33] > > at > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)[:1.6.0_33] > > at java.lang.reflect.Method.invoke(Method.java:597)[:1.6.0_33] > > at > > > org.apache.aries.blueprint.utils.ReflectionUtils.invoke(ReflectionUtils.java:225)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BeanRecipe.invoke(BeanRecipe.java:838)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BeanRecipe.destroy(BeanRecipe.java:743)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintRepository.destroy(BlueprintRepository.java:295)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintContainerImpl.destroyComponents(BlueprintContainerImpl.java:673)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintContainerImpl.destroy(BlueprintContainerImpl.java:826)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintExtender.destroyContext(BlueprintExtender.java:255)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintExtender.bundleChanged(BlueprintExtender.java:247)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.apache.aries.blueprint.container.BlueprintExtender$BlueprintBundleTrackerCustomizer.modifiedBundle(BlueprintExtender.java:471)[10:org.apache.aries.blueprint:0.3.1.fuse-70-084] > > at > > > org.osgi.util.tracker.BundleTracker$Tracked.customizerModified(BundleTracker.java:495)[karaf.jar:2.2.5.fuse-70-084] > > at > > > org.osgi.util.tracker.BundleTracker$Tracked.customizerModified(BundleTracker.java:1)[karaf.jar:2.2.5.fuse-70-084] > > at > > > org.osgi.util.tracker.AbstractTracked.track(AbstractTracked.java:238)[karaf.jar:2.2.5.fuse-70-084] > > at > > > org.osgi.util.tracker.BundleTracker$Tracked.bundleChanged(BundleTracker.java:457)[karaf.jar:2.2.5.fuse-70-084] > > at > > > org.apache.felix.framework.util.EventDispatcher.invokeBundleListenerCallback(EventDispatcher.java:870)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.apache.felix.framework.util.EventDispatcher.fireEventImmediately(EventDispatcher.java:791)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.apache.felix.framework.util.EventDispatcher.fireBundleEvent(EventDispatcher.java:515)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.apache.felix.framework.Felix.fireBundleEvent(Felix.java:4431)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.apache.felix.framework.Felix.stopBundle(Felix.java:2532)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.apache.felix.framework.BundleImpl.stop(BundleImpl.java:983)[org.apache.felix.framework-4.0.3.fuse-70-084.jar:] > > at > > > org.fusesource.fabric.agent.DeploymentAgent.updateDeployment(DeploymentAgent.java:709)[102:org.fusesource.fabric.fabric-agent:7.0.1.fuse-084] > > at > > > org.fusesource.fabric.agent.DeploymentAgent.doUpdate(DeploymentAgent.java:415)[102:org.fusesource.fabric.fabric-agent:7.0.1.fuse-084] > > at > > > org.fusesource.fabric.agent.DeploymentAgent$1.run(DeploymentAgent.java:225)[102:org.fusesource.fabric.fabric-agent:7.0.1.fuse-084] > > at > > > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_33] > > at > > > java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)[:1.6.0_33] > > at > java.util.concurrent.FutureTask.run(FutureTask.java:138)[:1.6.0_33] > > at > > > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_33] > > at > > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_33] > > at java.lang.Thread.run(Thread.java:662)[:1.6.0_33] > > > > > > > > > > # Exception 2, seen on box2: > > > > 2012-09-24 15:16:00,142 | INFO | spatch-DEFAULT-1 | TransportPool > > | 67 - org.fusesource.fabric.fabric-dosgi - 7.0.1.fuse-084 | Transport > > failure > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native > > Method)[:1.7.0_07] > > at > > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:692)[:1.7.0_07] > > at > > > org.fusesource.fabric.dosgi.tcp.TcpTransport$5.run(TcpTransport.java:483)[67:org.fusesource.fabric.fabric-dosgi:7.0.1.fuse-084] > > at > > > org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:228)[78:org.fusesource.hawtdispatch.hawtdispatch:1.9.0] > > at > > > org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:84)[78:org.fusesource.hawtdispatch.hawtdispatch:1.9.0] > > at > > > org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)[78:org.fusesource.hawtdispatch.hawtdispatch:1.9.0] > > 2012-09-24 15:16:00,147 | INFO | agent-1-thread-1 | DeploymentAgent > > | 63 - org.fusesource.fabric.fabric-agent - 7.0.1.fuse-084 | Done. > > > > > > # After which the logs are filled with: > > > > 2012-09-24 15:18:14,435 | INFO | nana.local:2181) | ClientCnxn > > | 54 - org.fusesource.fabric.fabric-linkedin-zookeeper - 7.0.1.fuse-084 | > > Opening socket connection to server banana.local/10.39.216.49:2181 > > 2012-09-24 15:18:14,436 | INFO | nana.local:2181) | ZooKeeperSaslClient > > | 54 - org.fusesource.fabric.fabric-linkedin-zookeeper - 7.0.1.fuse-084 | > > Client will not SASL-authenticate because the default JAAS configuration > > section 'Client' could not be found. If you are not using SASL, you may > > ignore this. On the other hand, if you expected SASL to work, please fix > > your JAAS configuration. > > 2012-09-24 15:18:14,437 | INFO | nana.local:2181) | ClientCnxn > > | 54 - org.fusesource.fabric.fabric-linkedin-zookeeper - 7.0.1.fuse-084 | > > Socket connection established to banana.local/10.39.216.49:2181, > initiating > > session > > 2012-09-24 15:18:14,438 | INFO | nana.local:2181) | ClientCnxn > > | 54 - org.fusesource.fabric.fabric-linkedin-zookeeper - 7.0.1.fuse-084 | > > Unable to read additional data from server sessionid 0x139f880728d0005, > > likely server has closed socket, closing socket connection and attempting > > reconnect > > > > > > From what I've read the SASL messages are safe to ignore, but exception 2 > > looks related to the problem - I don't think it's a configuration issue > with > > the OSes, the SocketChannel fails to connect but all ports are open and I > > can telnet remotely to that ip on port 2181. > > > > The code I'm using can be found here > > https://dl.dropbox.com/u/2465717/net.earcam.example.hello.tgz (just a > simple > > maven project). > > > > > > I'd be very grateful if anyone has a suggestions as to the cause, an RTFM > > with link, or a pointer to a working example, etc. > > > > > > thanks, > > > > Best regards, > > Caspar > > > > > > > > > > -- > Claus Ibsen > ----------------- > Red Hat, Inc. > FuseSource is now part of Red Hat > Email: cib...@redhat.com > Web: http://fusesource.com > Twitter: davsclaus > Blog: http://davsclaus.com > Author of Camel in Action: http://www.manning.com/ibsen >
