Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.distributeme.agents.transporter.generated;
  //CHECKSTYLE:OFF
  
  import org.slf4j.Logger;
  import java.util.List;
  import java.util.Map;
 
 // Generated by org.distributeme.generator.SkeletonGenerator
 
 	private static Logger log = LoggerFactory.getLogger(RemoteTransporterServiceSkeleton.class);
 
 
 	private long lastAccess;
 	private long created;
 
 	// CONCURRENCY CONTROL
 	// Class wide concurrency control strategy 
 
 	// CONCURRENCY CONTROL end
 
 		this(null);
 	}
 
 		 = System.currentTimeMillis();
 		 = anImplementation;
 	}
 
 		ServerSideCallContext diMeCallContext = new ServerSideCallContext("receiveAndAwakeAgent"__transportableCallContext);
 		diMeCallContext.setServiceId(TransporterServiceConstants.getServiceId());
 		ArrayList<ObjectdiMeParameters = new ArrayList<Object>();
 		diMeParameters.add(agent);
 		diMeCallContext.setParameters(diMeParameters);
 		InterceptionContext diMeInterceptionContext = new InterceptionContext();
 		// Initialize interceptors
 		List<ServerSideRequestInterceptordiMeInterceptors = InterceptorRegistry.getInstance().getServerSideRequestInterceptors();
 
 		ArrayList __return = new ArrayList();
 
 		for (ServerSideRequestInterceptor interceptor : diMeInterceptors){
 			InterceptorResponse interceptorResponse = interceptor.beforeServantCall(diMeCallContextdiMeInterceptionContext);
 			switch(interceptorResponse.getCommand()){
 			case :
 				if (interceptorResponse.getException() instanceof RuntimeException)
 					throw (RuntimeExceptioninterceptorResponse.getException();
 				if (interceptorResponse.getException() instanceof org.distributeme.agents.transporter.TransporterServiceException)
 				throw new RuntimeException("Interceptor exception",interceptorResponse.getException());
 			case :
 				__return.set(0, interceptorResponse.getReturnValue());
 				diMeInterceptionContext.setReturnValue(interceptorResponse.getReturnValue());
 				break;
 				__return.set(0, interceptorResponse.getReturnValue());
 				diMeInterceptionContext.setReturnValue(interceptorResponse.getReturnValue());
 				break;
 			case :
 				break;
 			} //...switch
 		} //...for
 		// Concurrency control, server side - 
 
 		try{
 			__return.add(diMeCallContext.getTransportableCallContext());
 			for (ServerSideRequestInterceptor interceptor : diMeInterceptors){
 				InterceptorResponse interceptorResponse = interceptor.afterServantCall(diMeCallContextdiMeInterceptionContext);
 				switch(interceptorResponse.getCommand()){
 				case :
 					if (interceptorResponse.getException() instanceof RuntimeException)
 						throw (RuntimeExceptioninterceptorResponse.getException();
 					if (interceptorResponse.getException() instanceof org.distributeme.agents.transporter.TransporterServiceException)
 					throw new RuntimeException("Interceptor exception",interceptorResponse.getException());
 				case :
 					__return.set(0, interceptorResponse.getReturnValue());
 					diMeInterceptionContext.setReturnValue(interceptorResponse.getReturnValue());
					break;
					__return.set(0, interceptorResponse.getReturnValue());
					diMeInterceptionContext.setReturnValue(interceptorResponse.getReturnValue());
					break;
				case :
					break;
//...switch
//...for
			return __return;
			if (Verbosity.logServerSideExceptions())
				.error("receiveAndAwakeAgent()"e);
			throw(e);
		}finally{
		}
	}
	// Service adapter methods
	public long getCreationTimestamp(){ return ; }
	public long getLastAccessTimestamp(){ return ; }
New to GrepCode? Check out our FAQ X