Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * #%L
   * Camel Talend Job Component
   * %%
   * Copyright (C) 2011 - 2012 Talend Inc.
   * %%
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
  * 
  *      http://www.apache.org/licenses/LICENSE-2.0
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  * #L%
  */
 
 package org.talend.camel;
 
 

Represents a Talend endpoint.

 
 public class TalendEndpoint extends DefaultEndpoint {
 
     private String clazz;
     private String context;
     private Object jobInstance;
     private Method jobMethod;
 
     public TalendEndpoint(String uriString clazzTalendComponent component) {
         super(uricomponent);
         this.setClazz(clazz);
     }
 
     public TalendEndpoint(String endpointUri) {
         super(endpointUri);
     }
 
     public Producer createProducer() throws Exception {
         instantiateJob();
         return new TalendProducer(this);
     }
 
     public Consumer createConsumer(Processor processorthrows Exception {
         throw new RuntimeCamelException("No support for exposing Camel as Talend job yet");
     }
 
     public boolean isSingleton() {
         return true;
     }
 
         if ( == null) {
             Class<?> jobType = this.getCamelContext().getClassResolver().resolveMandatoryClass();
              = getCamelContext().getInjector().newInstance(jobType);
              = jobType.getMethod("runJobInTOS"new Class[]{String[].class});
         }
     }
 
     public final void setClazz(String clazz) {
         this. = clazz;
     }
 
     public String getClazz() {
         return ;
     }
 
     public void setContext(String context) {
         this. = context;
     }
 
     public String getContext() {
         return ;
     }
 
     public void setJobInstance(Object jobInstance) {
         this. = jobInstance;
     }
 
     public Object getJobInstance() {
         return ;
     }
 
     public void setJobMethod(Method jobMethod) {
         this. = jobMethod;
     }
    public Method getJobMethod() {
        return ;
    }
New to GrepCode? Check out our FAQ X