Add a new source to the pipeline.

The source is given a reference to this DataPipeline as its callback.
547801
public VehicleDataSource addSource(VehicleDataSource source) {
        source.setCallback(this);
        mSources.add(source);
        if(isActive()) {
            source.onPipelineActivated();
        } else {
            source.onPipelineDeactivated();
        }
        return source;
    }
828473
def append(self, pipeline):
        
        for stage in pipeline.pipe:
            self._pipe.append(stage)
        return self
407542
def _add_reference(self, obj, ident=0):
        
        log_debug(
            "## New reference handle 0x{0:X}: {1} -> {2}".format(
                len(self.references) + self.BASE_REFERENCE_IDX,
                type(obj).__name__,
                repr(obj),
            ),
            ident,
        )
        self.references.append(obj)
1325368
function addEventSource(source) {
		source = _addEventSource(source);
		if (source) {
			pendingSourceCnt++;
			fetchEventSource(source, currentFetchID); // will eventually call reportEvents
		}
	}
1359392
def create_source(self, datapusher=True):
        
        task.create_source(self.target, self._preload_image(), datapusher)
888175
def addSource(self, itemSource):
        
        _IndexerInputSource(store=self.store, indexer=self, source=itemSource)
        itemSource.addReliableListener(self, style=iaxiom.REMOTE)
245699
private DataSource preCreate(Long pipelineId, DbMediaSource dbMediaSource) {

        if (CollectionUtils.isEmpty(dataSourceHandlers)) {
            return null;
        }

        DataSource dataSource = null;
        for (DataSourceHanlder handler : dataSourceHandlers) {
            if (handler.support(dbMediaSource)) {
                dataSource = handler.create(pipelineId, dbMediaSource);
                if (dataSource != null) {
                    return dataSource;
                }
            }
        }
        return null;
    }
141126
def add_config_source(self, config_source, position=None):
        
        rank = position if position is not None else len(self._config_sources)
        self._config_sources.insert(rank, config_source)
668967
private void addCommonHandlers(ChannelPipeline pipeline) {
        pipeline.addLast(Constants.DECOMPRESSOR_HANDLER, new HttpContentDecompressor());
        if (httpTraceLogEnabled) {
            pipeline.addLast(Constants.HTTP_TRACE_LOG_HANDLER,
                    new HttpTraceLoggingHandler(Constants.TRACE_LOG_UPSTREAM));
        }
    }
683820
def AddEventSource(self, event_source):
    
    self._RaiseIfNotWritable()

    event_source = self._PrepareAttributeContainer(event_source)

    self._event_sources.append(event_source)
    self.number_of_event_sources += 1
772118
@Override
    public void upgradeFrom(ChannelHandlerContext ctx) {
        final ChannelPipeline p = ctx.pipeline();
        p.remove(this);
    }
1212419
def add_source(self, name, location, schedule='Daily', op=''):
        
        if op == '':
            op = name + '.log'
        self.data_sources.append([name, location, schedule, op])
1319858
public void add( NameSource source ) {
        /*
            Unimplemented -
            Need to add an inner class util here that holds the source and
            monitors it by registering a listener
        */
        if ( sources == null )
            sources = new ArrayList();

        sources.add( source );
    }
621677
public void addSubscribedSource(Source source) {
        String sourceId = CollectorManagerUtils.getSourceId(source);
        //If present in pending subscription list remove it.
        pendingSubscriptions.remove(sourceId);
        subscribedSources.add(sourceId);
    }
1284195
def AddEventSource(self, event_source):
    
    self._RaiseIfNotWritable()

    self._storage_file.AddEventSource(event_source)
    self.number_of_event_sources += 1
605904
public boolean add(Msg msg, Pipe pipe)
    {
        assert (msg != null);
        assert (pipe != null);
        return addHelper(msg, 1, msg.size() - 1, pipe);
    }
759833
def set_source(self, source):
        """"""
        route = Navigator(source=self.source).navigate_to_source(source)

        # Save new source
        self.source = source

        return self._send_keystroke(route, wait=True)