itest/conversations-ws/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatelessImpl.java [41:184]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Service(interfaces={ConversationalClient.class})
public class ConversationalClientStatelessImpl implements ConversationalClient, ConversationalCallback {
   
    @Context
    protected ComponentContext componentContext;
    
    @Reference 
    protected ConversationalService conversationalService;
    
    @Reference 
    protected ConversationalService conversationalService2;
    
    @Reference
    protected ConversationalReferenceClient conversationalReferenceClient;
    
    private int clientCount = 0;
    private int callbackCount = 0;
    
    // a static member variable that records the number of times this service is called
    public static StringBuffer calls = new StringBuffer();    
	
    // From ConversationalClient
    public int runConversationFromInjectedReference(){
        calls.append("runConversationFromInjectedReference,");
        conversationalService.initializeCount(1);
        conversationalService.incrementCount();
        clientCount = conversationalService.retrieveCount();
        conversationalService.endConversation();
        
        return clientCount;
    }
    public int runConversationFromInjectedReference2(){
        calls.append("runConversationFromInjectedReference2,");   

        // now test the second reference        
        conversationalService2.initializeCount(1);
        conversationalService2.incrementCount();
        
        // stick in a call to the first reference to 
        // make sure the two references don't clash
        conversationalService.initializeCount(1);
        
        clientCount = conversationalService2.retrieveCount();
        conversationalService2.endConversation();
        
        // end the conversation through the first reference
        conversationalService.endConversation();
        
        return clientCount;
    }
    public int runConversationFromServiceReference(){
        calls.append("runConversationFromServiceReference,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");       
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        // serviceReference.getConversation().end();
        
        return clientCount;
    }   
    public int runConversationWithUserDefinedConversationId(){
        calls.append("runConversationWithUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");
        serviceReference.setConversationID("MyConversation1");
        
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        // serviceReference.getConversation().end();
        
        return clientCount;
    }    
    public String runConversationCheckUserDefinedConversationId(){
        calls.append("runConversationCheckUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");
        serviceReference.setConversationID("MyConversation2");
        
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        
        String clientConversationId = serviceReference.getConversationID().toString();
        String serverConfersationId = callableReference.endConversation();
        
        if (clientConversationId.equals("MyConversation2") &&
            serverConfersationId.equals("MyConversation2") ) {
            return clientConversationId;
        } else {
            return "client = " + clientConversationId +
                   "server = " + serverConfersationId;
        }     
    }     
    public int runConversationCheckingScope(){
        calls.append("runConversationCheckingScope,");
        // run a conversation
        return runConversationFromInjectedReference();
        
        // test will then use a static method to find out how many times 
        // init/destroy were called
    }
    public int runConversationWithCallback(){
        calls.append("runConversationWithCallback,");
        conversationalService.initializeCountCallback(1);
        conversationalService.incrementCountCallback();
        clientCount = conversationalService.retrieveCountCallback();
        conversationalService.endConversationCallback();
        
        return clientCount;
    } 
    
    public int runConversationHavingPassedReference(){
        calls.append("runConversationHavingPassedReference,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");       
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        conversationalReferenceClient.incrementCount(serviceReference);
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        serviceReference.getConversation().end();
        
        return clientCount;
    }	
    
    public String runConversationBusinessException(){
	    calls.append("runConversationbusinessException,");	    
	    try {
            conversationalService.initializeCount(1);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatelessImpl.java [40:183]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Service(interfaces={ConversationalClient.class})
public class ConversationalClientStatelessImpl implements ConversationalClient, ConversationalCallback {
   
    @Context
    protected ComponentContext componentContext;
    
    @Reference 
    protected ConversationalService conversationalService;
    
    @Reference 
    protected ConversationalService conversationalService2;
    
    @Reference
    protected ConversationalReferenceClient conversationalReferenceClient;
    
    private int clientCount = 0;
    private int callbackCount = 0;
    
    // a static member variable that records the number of times this service is called
    public static StringBuffer calls = new StringBuffer();    
	
    // From ConversationalClient
    public int runConversationFromInjectedReference(){
        calls.append("runConversationFromInjectedReference,");
        conversationalService.initializeCount(1);
        conversationalService.incrementCount();
        clientCount = conversationalService.retrieveCount();
        conversationalService.endConversation();
        
        return clientCount;
    }
    public int runConversationFromInjectedReference2(){
        calls.append("runConversationFromInjectedReference2,");   

        // now test the second reference        
        conversationalService2.initializeCount(1);
        conversationalService2.incrementCount();
        
        // stick in a call to the first reference to 
        // make sure the two references don't clash
        conversationalService.initializeCount(1);
        
        clientCount = conversationalService2.retrieveCount();
        conversationalService2.endConversation();
        
        // end the conversation through the first reference
        conversationalService.endConversation();
        
        return clientCount;
    }
    public int runConversationFromServiceReference(){
        calls.append("runConversationFromServiceReference,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");       
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        // serviceReference.getConversation().end();
        
        return clientCount;
    }   
    public int runConversationWithUserDefinedConversationId(){
        calls.append("runConversationWithUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");
        serviceReference.setConversationID("MyConversation1");
        
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        // serviceReference.getConversation().end();
        
        return clientCount;
    }    
    public String runConversationCheckUserDefinedConversationId(){
        calls.append("runConversationCheckUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");
        serviceReference.setConversationID("MyConversation2");
        
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        
        String clientConversationId = serviceReference.getConversationID().toString();
        String serverConfersationId = callableReference.endConversation();
        
        if (clientConversationId.equals("MyConversation2") &&
            serverConfersationId.equals("MyConversation2") ) {
            return clientConversationId;
        } else {
            return "client = " + clientConversationId +
                   "server = " + serverConfersationId;
        }     
    }     
    public int runConversationCheckingScope(){
        calls.append("runConversationCheckingScope,");
        // run a conversation
        return runConversationFromInjectedReference();
        
        // test will then use a static method to find out how many times 
        // init/destroy were called
    }
    public int runConversationWithCallback(){
        calls.append("runConversationWithCallback,");
        conversationalService.initializeCountCallback(1);
        conversationalService.incrementCountCallback();
        clientCount = conversationalService.retrieveCountCallback();
        conversationalService.endConversationCallback();
        
        return clientCount;
    } 
    
    public int runConversationHavingPassedReference(){
        calls.append("runConversationHavingPassedReference,");
        ServiceReference<ConversationalService> serviceReference = componentContext.getServiceReference(ConversationalService.class, 
                                                                                                        "conversationalService");       
        ConversationalService callableReference = serviceReference.getService();
        
        callableReference.initializeCount(1);
        callableReference.incrementCount();
        conversationalReferenceClient.incrementCount(serviceReference);
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();
        
        serviceReference.getConversation().end();
        
        return clientCount;
    }	
    
    public String runConversationBusinessException(){
	    calls.append("runConversationbusinessException,");	    
	    try {
            conversationalService.initializeCount(1);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -