Package org.apache.tuscany.sca.runtime

Examples of org.apache.tuscany.sca.runtime.EndpointReference

657
658
659
660
661
662
663
664
665
666
667
668
669
        }
        InterfaceContract targetContract = targetService.getInterfaceContract().makeUnidirectional(false);

        InterfaceContract sourceContract = getInterfaceContract(service, serviceBinding);

        EndpointReference wireSource = new EndpointReferenceImpl(null, null, serviceBinding, sourceContract);

        EndpointReference wireTarget =
            new EndpointReferenceImpl((RuntimeComponent)serviceComponent, (RuntimeComponentService)service,
                                      serviceBinding, targetContract);

        RuntimeWire wire =
            new RuntimeWireImpl(wireSource, wireTarget, interfaceContractMapper, workScheduler, wireProcessor,
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    /**
     * @param msgContext
     */
    private static EndpointReference getCallbackEndpoint(Message msgContext) {
        EndpointReference from = msgContext.getFrom();
        if (from == null) {
            return null;
        }
        return from.getReferenceParameters().getCallbackReference();
    }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
        }
        return from.getReferenceParameters().getCallbackReference();
    }

    private static RuntimeWire cloneAndBind(Message msgContext, RuntimeWire wire) {
        EndpointReference callback = getCallbackEndpoint(msgContext);
        if (callback != null) {
            try {
                if (callback.getContract() == null) {
                    return (RuntimeWire)wire.clone();  //FIXME: add caching
                }
                RuntimeComponentReference ref = null;
                if (callback.getContract() instanceof RuntimeComponentReference) {
                    ref = (RuntimeComponentReference)callback.getContract();
                    return ref.getRuntimeWire(callback.getBinding());
                } else {
                    ref =
                        bind((RuntimeComponentReference)wire.getSource().getContract(),
                             callback.getComponent(),
                             (RuntimeComponentService)callback.getContract());

                    return ref.getRuntimeWires().get(0);
                }
            } catch (CloneNotSupportedException e) {
                // will not happen
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
        }

        Object callbackID = msgContext.getFrom().getReferenceParameters().getCallbackID();
        ((CallbackReferenceImpl)callableReference).attachCallbackID(callbackID);

        EndpointReference epr = msgContext.getFrom().getReferenceParameters().getCallbackReference();
        setEndpoint(epr);

        // need to set the endpoint on the binding also so that when the chains are created next
        // the sca binding can decide whether to provide local or remote invokers.
        // TODO - there is a problem here though in that I'm setting a target on a
        //        binding that may possibly be trying to point at two things in the multi threaded
        //        case. Need to confirm the general model here and how the clone and bind part
        //        is intended to work
        wire.getSource().getBinding().setURI(epr.getURI());

        // also need to set the target contract as it varies for the sca binding depending on
        // whether it is local or remote
        RuntimeComponentReference ref = (RuntimeComponentReference)wire.getSource().getContract();
        Binding binding = wire.getSource().getBinding();
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
73
74
75
        ConversationSequence sequence = op.getConversationSequence();
        Object payload = msg.getBody();

        Object contextId = null;

        EndpointReference from = msg.getFrom();
        ReferenceParameters parameters = null;
        if (from != null) {
            parameters = from.getReferenceParameters();
        }
        // check what sort of context is required
        if (scopeContainer != null) {
            Scope scope = scopeContainer.getScope();
            if (scope == Scope.REQUEST) {
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
77
78
79
        ConversationSequence sequence = op.getConversationSequence();
        Object payload = msg.getBody();

        Object contextId = null;

        EndpointReference from = msg.getFrom();
        ReferenceParameters parameters = null;
        if (from != null) {
            parameters = from.getReferenceParameters();
        }
        // check what sort of context is required
        if (scopeContainer != null) {
            Scope scope = scopeContainer.getScope();
            if (scope == Scope.REQUEST) {
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
82
83
        Implementation implementation = component.getImplementation();
        if (!(implementation instanceof JavaImplementation)) {
            return;
        }
        JavaImplementation javaImpl = (JavaImplementation)implementation;
        EndpointReference callbackEndpoint = wire.getSource().getCallbackEndpoint();
        if (callbackEndpoint != null) {
            Interface iface = callbackEndpoint.getContract().getInterfaceContract().getInterface();
            if (!supportsCallbackInterface(iface, javaImpl)) {
                // callback to this impl is not possible, so ensure a callback object is set
                for (InvocationChain chain : wire.getInvocationChains()) {
                    chain.addInterceptor(Phase.REFERENCE, new CallbackInterfaceInterceptor());
                }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
128
129
130
    protected ReferenceParameters getReferenceParameters() {
        ReferenceParameters parameters = super.getReferenceParameters();
        if (callback != null) {
            if (callback instanceof ServiceReference) {
                EndpointReference callbackRef = ((CallableReferenceImpl)callback).getEndpointReference();
                parameters.setCallbackReference(callbackRef);
            } else {
                EndpointReference callbackRef = getRuntimeWire().getSource().getCallbackEndpoint();
                parameters.setCallbackReference(callbackRef);
                parameters.setCallbackObjectID(callback);
            }
        }
        return parameters;
View Full Code Here
327
328
329
330
331
332
333
334
335
336
337
        }

        Interface interfaze = msg.getOperation().getInterface();
        if (callbackObject != null) {
            if (callbackObject instanceof ServiceReference) {
                EndpointReference callbackRef = ((CallableReferenceImpl)callbackObject).getEndpointReference();
                parameters.setCallbackReference(callbackRef);
            } else {
                if (interfaze != null) {
                    if (!interfaze.isConversational()) {
                        throw new IllegalArgumentException(
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
    }

    public static RuntimeComponent getCurrentComponent() {
        Message message = ThreadMessageContext.getMessageContext();
        if (message != null) {
            EndpointReference to = message.getTo();
            if (to == null) {
                return null;
            }
            RuntimeComponent component = message.getTo().getComponent();
            return component;
View Full Code Here
TOP

Related Classes of org.apache.tuscany.sca.runtime.EndpointReference

  • org.apache.tuscany.sca.binding.jms.provider.DefaultJMSBindingListener
  • org.apache.tuscany.sca.binding.jms.transport.TransportServiceInterceptor
  • org.apache.tuscany.sca.binding.sca.axis2.impl.Axis2SCABindingInvoker
  • org.apache.tuscany.sca.binding.sca.impl.RuntimeSCAReferenceBindingProvider
  • org.apache.tuscany.sca.binding.sca.provider.RuntimeSCAReferenceBindingProvider
  • org.apache.tuscany.sca.binding.ws.axis2.Axis2ServiceProvider
  • org.apache.tuscany.sca.core.assembly.CompositeActivatorImpl
  • org.apache.tuscany.sca.core.assembly.impl.CompositeActivatorImpl
  • org.apache.tuscany.sca.core.assembly.impl.RuntimeWireImpl2
  • org.apache.tuscany.sca.core.context.CallableReferenceImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.