On 8/23/07, Simon Nash <[EMAIL PROTECTED]> wrote:
>
> Giorgio,
> This is supported and working for both the local SCA binding and the
> Web Service binding. The supportsAsyncOneWayInvocation=false setting
> means that the binding doesn't provide this support internally, so the
> core invocation framework adds a nonblocking interceptor that does a
> thread switch. It appears that you are using the distributed
> SCA binding over Web services (is that correct?) so there could be an
> issue with this binding. Bindings that can support async invocations
> internally are supposed to set the flag to true rather than false,
> and I'd expect the distributed SCA binding to fall into that category.
>
> Simon
>
> Giorgio Zoppi wrote:
>
> > Hi,
> >
> > Yesterday i was doing tests with SCA, but it doesn't do asynchronous
> remote invocation. I need it because I'm working
> > with streams of values.
> > For example:
> >
> > import org.osoa.sca.annotations.OneWay;
> > import org.osoa.sca.annotations.Remotable;
> > /**
> > * This service that will be invoked in a non-blocking fashion
> > */
> > @Remotable
> > public interface WorkerService {
> >
> > @OneWay
> > public void compute(int value);
> > }
> >
> > And this is its implementation:
> >
> > @Service(WorkerService.class)
> > public class WorkerServiceImpl implements WorkerService {
> >
> >
> > public void compute(int value)
> > {
> > System.out.println("Input Value = " + value);
> >
> > }
> >
> > }
> >
> > This is the client:
> >
> > @Service(Workpool.class)
> > public class WorkpoolImpl implements Workpool {
> >
> > private WorkerService myService2;
> > @Reference
> > public void setMyService2(WorkerService myService2) {
> > this.myService2 = myService2;
> > }
> > public void submit(int value) {
> > myService2.compute(value);
> > }
> >
> > }
> > And these are the bindings:
> > JVM_C
> > <composite xmlns="http://www.osoa.org/xmlns/sca/1.0";
> > targetNamespace="http://sample";
> > xmlns:sample="http://sample";
> > name="Workpool">
> >
> > <component name="WorkerServiceComponent2">
> > <implementation.java class="workpool.WorkerServiceImpl" />
> > <service name="WorkerService">
> > <binding.sca
> > uri="http://localhost:8086/WorkerServiceComponent2"/>
> > </service>
> > </component>
> >
> > </composite>
> > JVM_B : domainNode
> > JVM_A:
> > <composite xmlns="http://www.osoa.org/xmlns/sca/1.0";
> > targetNamespace="http://sample";
> > xmlns:sample="http://sample";
> > name="Workpool">
> >
> > <component name="WorkpoolServiceComponent">
> > <implementation.java class="workpool.WorkpoolImpl"/>
> > <reference name="myService2" target="WorkerServiceComponent2"/>
> > </component>
> >
> >
> > </composite>
> >
> > In my Node I have:
> >
> > if ( nodeName.equals("nodeA") ) {
> > Workpool myClient = domain.getService(Workpool.class,
> > "WorkpoolServiceComponent");
> >
> >
> > for (int j = 1; j < 18; ++j )
> > {
> > myClient.submit(j);
> > }
> >
> > }
> >
> > Its output:
> > $ ant
> > Buildfile: build.xml
> >
> > runNodeC:
> > [java]
> >
> file:/home/giorgio/sca.onwork/java/sca/samples/workpool/target/classes/management/
> > [java] log4j:WARN No appenders could be found for logger
> > (org.apache.axiom.om.util.StAXUtils).
> > [java] log4j:WARN Please initialize the log4j system properly.
> > [java] ContributionURL
> >
> =file:/home/giorgio/sca.onwork/java/sca/samples/workpool/target/classes/nodeC/
> > [java] My composite={http://sample}Workpool
> > [java] Registering service: [mydomain nodeC WorkerServiceComponent2
> > org.apache.tuscany.sca.assembly.SCABinding
> > http://localhost:8086/WorkerServiceComponent2]
> > [java] Registering service: [mydomain nodeC
> > WorkerServiceComponent2/WorkerService
> > org.apache.tuscany.sca.assembly.SCABinding
> > http://localhost:8086/WorkerServiceComponent2]
> > [java] Added Servlet mapping:
> > http://localhost:8086/WorkerServiceComponent2
> > [java] Node started (press enter to shutdown)
> > [java] Input Value = 4
> > [java] Input Value = 3
> >
> > Instead of 18 values, which I should receive.
> > But I'm now seeing in Axis2SCAReferenceBindingProvider..
> >
> >
> > public boolean supportsAsyncOneWayInvocation() {
> > return false;
> > }
> >
> > It seems that current runtime doesn't support it. Is there a some who's
> working on it before i'm going to implement it.
> > The same seems for remote Callbacks, are they working?
> >
> > Cheers,
> > Jo.
> >
> > P.S You can find my code tarball at components
> http://components.ath.cx/sample-sca.tar.gz
> >
> >
> >
> > ---------------------------------------------------------------------
> > To unsubscribe, e-mail: [EMAIL PROTECTED]
> > For additional commands, e-mail: [EMAIL PROTECTED]
> >
> >
> >
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [EMAIL PROTECTED]
> For additional commands, e-mail: [EMAIL PROTECTED]
>
> Hi Jo
I'm fixing up the remote callbacks for the sca binding now. They should
already work for the local case and explicit web services bindings (see
samples/simple-callback and samples/simple-callback-ws) It needs changing
in the sca binding case now that raymond has changed the way that the
wires/invocation chains are created. If you want to make progress with
you're sample right now you could switch to the explicit web services
binding for the time being. Otherwise the fix should be done in an hour or
so (I hope:-)
With one way invocations you've found something I haven't tried with the
default binding in remote mode. It's just using the web services binding
under the covers so there's no reason why it shouldn't work but I expect
there is some coding error. If you've got some thoughts here about what's
going wrong that would would good.
Regards
Simon L
