itest/conversations-ws/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java [43:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Service(interfaces={ConversationalClient.class})
@Scope("CONVERSATION")
@ConversationAttributes(maxAge="10 minutes",
                        maxIdleTime="5 minutes",
                        singlePrincipal=false)
public class ConversationalClientStatefulNonConversationalCallbackImpl implements ConversationalClient, NonConversationalCallback {
    
    @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,");
               
        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();
        return callableReference.endConversation();
              
    }      
    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,");
	    callbackCount = 2;
        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/ConversationalClientStatefulNonConversationalCallbackImpl.java [42:179]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Service(interfaces={ConversationalClient.class})
@Scope("CONVERSATION")
@ConversationAttributes(maxAge="10 minutes",
                        maxIdleTime="5 minutes",
                        singlePrincipal=false)
public class ConversationalClientStatefulNonConversationalCallbackImpl implements ConversationalClient, NonConversationalCallback {
    
    @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,");
               
        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();
        return callableReference.endConversation();
              
    }      
    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,");
	    callbackCount = 2;
        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);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -