Re: Multiple CORBA clients

Your question is fearing me. Do you mean you tested
shark server and noticed it can't currently allow for
multiple users manipulating workflows at the same time?
If so we are in trouble here, as we never noticed any problem :)

Here is an extract from a unit-test i developped to skill myself at
using shark CORBA interfaces, this all works without extending shark
in any way:

    public void testStartWorkflow() throws Exception {
        String packname= null;
        SharkInterface interf = aquireCorba("Shark-Unittest",
"localhost", "10123");
        assertTrue("Should be able to upload basic test
wf",uploadPackage("xpdl","test-BeanShell.xpdl",interf));
        assertNotNull("Should be able to open package for basic test
wf",packname = activatePackage("test-BeanShell.xpdl",interf));
       
addMapping("worker1","group1","test_bs","manufacturing",true,interf);
       
addMapping("worker2","group2","test_bs","manufacturing",true,interf);
       
addMapping("composer","group3","test_bs","manufacturing",true,interf);
        SharkConnection connection = interf.getSharkConnection();
        connection.connect("admin","enhydra","","");
        WfProcess process =
connection.createProcess(packname,"manufacturing");
        assertNotNull("Should be able to create process",process);       
        process.start();
        WfResource res = connection.getResourceObject();
        assertNotNull("Ressource object should not be null", res);
        WfAssignment[] ass = res.get_sequence_work_item(0);
        if (ass!=null)
            for (int i = 0;i<ass.length;i++){
                System.out.println("ass["+i+"]:
"+ass[i].activity().name()+" -> "+ass[i].assignee().resource_key());
                ass[i].set_accepted_status(true);
                ass[i].activity().complete();
            }

        SharkConnection worker1 = interf.getSharkConnection();
        SharkConnection worker2 = interf.getSharkConnection();
        SharkConnection composer = interf.getSharkConnection();
        worker1.connect("user1","passwd","","");
        worker2.connect("user2","passwd","","");
        composer.connect("user3","passwd","","");
       
        res=worker1.getResourceObject();
        assertNotNull("Ressource object should not be null", res);
        ass = res.get_sequence_work_item(0);
        if (ass!=null)
            for (int i = 0;i<ass.length;i++){
                System.out.println("ass["+i+"]:
"+ass[i].activity().name()+" -> "+ass[i].assignee().resource_key());
                ass[i].set_accepted_status(true);
                ass[i].activity().complete();
            }

        res=worker2.getResourceObject();
        assertNotNull("Ressource object should not be null", res);
        ass = res.get_sequence_work_item(0);
        if (ass!=null)
            for (int i = 0;i<ass.length;i++){
                System.out.println("ass["+i+"]:
"+ass[i].activity().name()+" -> "+ass[i].assignee().resource_key());
                ass[i].set_accepted_status(true);
                ass[i].activity().complete();
            }

        res=composer.getResourceObject();
        assertNotNull("Ressource object should not be null", res);
        ass = res.get_sequence_work_item(0);
        if (ass!=null)
            for (int i = 0;i<ass.length;i++){
                System.out.println("ass["+i+"]:
"+ass[i].activity().name()+" -> "+ass[i].assignee().resource_key());
                ass[i].set_accepted_status(true);
                ass[i].activity().complete();
            }
       
        ass = res.get_sequence_work_item(0);
        if (ass!=null)
            for (int i = 0;i<ass.length;i++){
                System.out.println("ass["+i+"]:
"+ass[i].activity().name()+" -> "+ass[i].assignee().resource_key());
                ass[i].set_accepted_status(true);
                ass[i].activity().complete();
            }
       
        //assertTrue("Should be able to close package for basic test
wf",closePackage(packname,interf));
        assertEquals("state must be
closed.completed","closed.completed",process.state());
        interf.doneWith(res);
        assertFalse("Should be NOT be able to close package (completed
process depending on it)",closePackage(packname,interf));
        ExecutionAdministration exec = interf.getExecutionAdministration();
        exec.connect("admin","enhydra","","");
        exec.deleteClosedProcesses();
        assertTrue("Should be able to close package (completed process
are now removed)",closePackage(packname,interf));
        interf.doneWith(worker1);
        interf.doneWith(worker2);
        interf.doneWith(composer);
        interf.doneWith(exec);
    }

Note, our addMapping method just add users with corresponding groups to
userdatabase.

Dirk Hoffmann a écrit :

>Hi,
>
>we are using shark to build a software production system that manges the
>building, testing and delivery of software packages.
>
>The processes will consist of worklist and *tool agent* activities.
>
>Developers, release managers, testers, etc. are the participants. They
>are working on different machines around the office. The "shark server"
>is supposed to reside on another machine.
>
>To make the server reachable via network we are going to start with the
>CORBA admin and worklist clients that come with shark as they seem more
>mature and complete than the available web interfaces.
>
>Eventually we will develop our own web interface based on the echo
>(http://www.nextapp.com/products/echo/)
><http://www.nextapp.com/products/echo/>
> framework.
>
>For now we add some features to the existing CORBA clients such as
>JTextArea components for multiline text in the "Update Process
>Variables" view. More extensions will be radioboxes, checkboxes or menus
>for process variables of type java.util.Map where the value is of type
>Boolean.
>
>So now the question:
>What do we have to add to shark to make it a real multiuser
>client/server application?
>
>I guess the SharkCORBAServer class needs to be extended in some way to
>allow multiple clients to connect to the workflow system.
>
>Is somebody willing to share experience and code examples (we are)?
>
>Best regards,
>Dirk
>
>
>
>
>
>  
>
>------------------------------------------------------------------------
>
>
>--
>You receive this message as a subscriber of the [email protected] mailing list.
>To unsubscribe: mailto:[email protected]
>For general help: mailto:[email protected]?subject=help
>ObjectWeb mailing lists service home page: http://www.objectweb.org/wws
>  
>

--
You receive this message as a subscriber of the [email protected] mailing list.
To unsubscribe: mailto:[email protected]
For general help: mailto:[email protected]?subject=help
ObjectWeb mailing lists service home page: http://www.objectweb.org/wws