Package org.apache.tuscany.sca.core.invocation

Examples of org.apache.tuscany.sca.core.invocation.MessageImpl

260
261
262
263
264
265
266
267
268
            throw new RuntimeException(e);
        }
    }
   
    protected void invoke(InvocationChain chain, Object[] args) {
        Message msg = new MessageImpl();
        msg.setBody(args);
        chain.getHeadInvoker().invoke(msg);
    }
View Full Code Here
46
47
48
49
50
51
52
    public Message invoke(Message requestMsg) {

        invoke((Object[])requestMsg.getBody());

        // DWR references can not return anything
        return new MessageImpl();
    }
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
117
118
        return (Remote)enhancer.create();
    }

    protected Object invokeTarget(Operation op, Object[] args) throws InvocationTargetException {

        Message requestMsg = new MessageImpl();
        ThreadMessageContext.setMessageContext(requestMsg);
        requestMsg.setBody(args);

        Message responseMsg = service.getInvoker(binding, op).invoke(requestMsg);

        if (responseMsg.isFault()) {
            throw new InvocationTargetException((Throwable)responseMsg.getBody());
View Full Code Here
41
42
43
44
45
46
47
    public Message invoke(Message requestMsg) {

        invoke((Object[])requestMsg.getBody());

        // Ajax references can not return anything
        return new MessageImpl();
    }
View Full Code Here
46
47
48
49
50
51
52
    public Message invoke(Message requestMsg) {

        invoke((Object[])requestMsg.getBody());

        // DWR references can not return anything
        return new MessageImpl();
    }
View Full Code Here
256
257
258
259
260
261
262
263
264
            throw new RuntimeException(e);
        }
    }
   
    protected void invoke(InvocationChain chain, Object[] args) {
        Message msg = new MessageImpl();
        msg.setBody(args);
        chain.getHeadInvoker().invoke(msg);
    }
View Full Code Here
41
42
43
44
45
46
47
    public Message invoke(Message requestMsg) {

        invoke((Object[])requestMsg.getBody());

        // DWR references can not return anything
        return new MessageImpl();
    }
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
117
118
        return (Remote)enhancer.create();
    }

    protected Object invokeTarget(Operation op, Object[] args) throws InvocationTargetException {

        Message requestMsg = new MessageImpl();
        ThreadMessageContext.setMessageContext(requestMsg);
        requestMsg.setBody(args);

        Message responseMsg = service.getInvoker(binding, op).invoke(requestMsg);

        if (responseMsg.isFault()) {
            throw new InvocationTargetException((Throwable)responseMsg.getBody());
View Full Code Here
252
253
254
255
256
257
258
259
260
            throw new RuntimeException(e);
        }
    }
   
    protected void invoke(InvocationChain chain, Object[] args) {
        Message msg = new MessageImpl();
        msg.setBody(args);
        chain.getHeadInvoker().invoke(msg);
    }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
    protected Object invokeService(Message requestJMSMsg) throws JMSException, InvocationTargetException {

        String operationName = requestMessageProcessor.getOperationName(requestJMSMsg);
        Operation operation = getTargetOperation(operationName);

        MessageImpl tuscanyMsg = new MessageImpl();
        tuscanyMsg.setOperation(operation);
        if ("onMessage".equals(operation.getName())) {
            tuscanyMsg.setBody(new Object[]{requestJMSMsg});
        } else {
            Object requestPayload = requestMessageProcessor.extractPayloadFromJMSMessage(requestJMSMsg);
            tuscanyMsg.setBody(requestPayload);
        }

        setHeaderProperties(requestJMSMsg, tuscanyMsg, operation);

        return service.getRuntimeWire(targetBinding).invoke(operation, tuscanyMsg);
View Full Code Here
TOP

Related Classes of org.apache.tuscany.sca.core.invocation.MessageImpl

  • org.apache.tuscany.sca.binding.ajax.AjaxInvoker
  • org.apache.tuscany.sca.binding.dwr.DWRInvoker
  • org.apache.tuscany.sca.binding.jms.provider.DefaultJMSBindingListener
  • org.apache.tuscany.sca.binding.notification.NotificationServiceBindingProvider
  • org.apache.tuscany.sca.binding.rmi.RMIService
  • org.apache.tuscany.sca.core.assembly.EndpointReferenceImpl
    • 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.