org.apache.tuscany.sca.core.invocation
Class RuntimeWireInvoker

java.lang.Object
  org.apache.tuscany.sca.core.invocation.RuntimeWireInvoker

All Implemented Interfaces:

Invoker

public class RuntimeWireInvoker
extends java.lang.Object
implements Invoker

Field Summary

protected java.lang.Object	callbackID
protected java.lang.Object	callbackObject
protected ExtendedConversation	conversation
protected boolean	conversational
protected java.lang.Object	conversationID
protected ConversationManager	conversationManager
protected MessageFactory	messageFactory
protected RuntimeWire	wire

Constructor Summary

RuntimeWireInvoker(MessageFactory messageFactory, ConversationManager conversationManager, RuntimeWire wire)

Method Summary

protected EndpointReference	getCallbackEndpoint(Message msgContext)
protected void	init(RuntimeWire wire)
protected java.lang.Object	invoke(InvocationChain chain, Message msg, RuntimeWire wire)
Message	invoke(Message msg) Process a synchronous wire
java.lang.Object	invoke(Operation operation, Message msg)
java.lang.Object	invoke(RuntimeWire wire, Operation operation, Message msg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

conversationManager

protected ConversationManager conversationManager

conversational

protected boolean conversational

conversation

protected ExtendedConversation conversation

messageFactory

protected MessageFactory messageFactory

conversationID

protected java.lang.Object conversationID

callbackID

protected java.lang.Object callbackID

callbackObject

protected java.lang.Object callbackObject

wire

protected RuntimeWire wire

Constructor Detail

RuntimeWireInvoker

public RuntimeWireInvoker(MessageFactory messageFactory,
                          ConversationManager conversationManager,
                          RuntimeWire wire)

Method Detail

init

protected void init(RuntimeWire wire)

invoke

public Message invoke(Message msg)

Description copied from interface: Invoker

Process a synchronous wire

Specified by:

invoke in interface Invoker

Parameters:

msg - The request Message for the wire

Returns:

The response Message from the wire

invoke

public java.lang.Object invoke(Operation operation,
                               Message msg)
                        throws java.lang.reflect.InvocationTargetException

Throws:

java.lang.reflect.InvocationTargetException

invoke

public java.lang.Object invoke(RuntimeWire wire,
                               Operation operation,
                               Message msg)
                        throws java.lang.reflect.InvocationTargetException

Throws:

java.lang.reflect.InvocationTargetException

invoke

protected java.lang.Object invoke(InvocationChain chain,
                                  Message msg,
                                  RuntimeWire wire)
                           throws java.lang.reflect.InvocationTargetException

Throws:

java.lang.reflect.InvocationTargetException

getCallbackEndpoint

protected EndpointReference getCallbackEndpoint(Message msgContext)

Parameters:

msgContext -