Method setPubSubInputHandler.
@param pubSubInputHandler
193907
public void setPubSubInputHandler(PubSubInputHandler pubSubInputHandler)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "setPubSubInputHandler", pubSubInputHandler);
    this.pubSubInputHandler = pubSubInputHandler;
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "setPubSubInputHandler");
  }
182928
@Override
    public void setObserver(HttpOutputStreamObserver obs) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) {
            Tr.debug(tc, "obs  ->" + obs);
        }
        this.obs = obs;
    }
779128
public void setPubsNumber(final Integer pubsNumber) {
        if (pubsNumber == null && this.pubsNumber == null) {
            return;
        } else if (pubsNumber == null) {
            removeChild(this.pubsNumber);
            this.pubsNumber = null;
        } else if (this.pubsNumber == null) {
            this.pubsNumber = new KeyValueNode<Integer>(CommonConstants.CS_PUBSNUMBER_TITLE, pubsNumber);
            appendChild(this.pubsNumber, false);
        } else {
            this.pubsNumber.setValue(pubsNumber);
        }
    }
791167
public void setInputUpdates(java.util.Collection<InputUpdate> inputUpdates) {
        if (inputUpdates == null) {
            this.inputUpdates = null;
            return;
        }

        this.inputUpdates = new java.util.ArrayList<InputUpdate>(inputUpdates);
    }
1256292
@Override
    public HashMap getAllPubSubOutputHandlers()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "getAllPubSubOutputHandlers");

        HashMap pubsubOutputHandlers = _targetDestinationHandler.getAllPubSubOutputHandlers();

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getAllPubSubOutputHandlers", pubsubOutputHandlers);

        return pubsubOutputHandlers;
    }
1179192
public void setSubProtocols(String[] subProtocols) {
        if (subProtocols == null || subProtocols.length == 0) {
            this.subProtocols = null;
            return;
        }
        this.subProtocols = Arrays.asList(subProtocols);
    }
641342
public void addHandler(Handler handler) {
        if (null == handlers) {
            handlers = new ArrayList<>();
        }
        handlers.add(handler);
    }
1166636
public static void finalizeHandler(Bootstrap b,
			ChannelOperations.OnSetup opsFactory,
			ConnectionObserver listener) {
		Objects.requireNonNull(b, "bootstrap");
		Objects.requireNonNull(listener, "listener");

		BootstrapPipelineHandler pipeline = null;
		ChannelHandler handler = b.config().handler();
		if (handler instanceof BootstrapPipelineHandler){
			pipeline = (BootstrapPipelineHandler) handler;
		}


		if (pipeline != null) {
			PipelineConfiguration pipelineConfiguration;
			for (int i = 0; i < pipeline.size(); i++) {
				pipelineConfiguration = pipeline.get(i);
				if (pipelineConfiguration.deferredConsumer != null) {
					pipeline.set(i,
							new PipelineConfiguration(
									pipelineConfiguration.deferredConsumer.apply(b),
									pipelineConfiguration.name));
				}
			}
		}

		b.handler(new BootstrapInitializerHandler(pipeline, opsFactory, listener));
	}
85746
public void setPubTypeList(FSArray v) {
    if (Header_Type.featOkTst && ((Header_Type)jcasType).casFeat_pubTypeList == null)
      jcasType.jcas.throwFeatMissing("pubTypeList", "de.julielab.jules.types.Header");
    jcasType.ll_cas.ll_setRefValue(addr, ((Header_Type)jcasType).casFeatCode_pubTypeList, jcasType.ll_cas.ll_getFSRef(v));}
1000742
public void setPubDate(Date v) {
    if (PubType_Type.featOkTst && ((PubType_Type)jcasType).casFeat_pubDate == null)
      jcasType.jcas.throwFeatMissing("pubDate", "de.julielab.jules.types.PubType");
    jcasType.ll_cas.ll_setRefValue(addr, ((PubType_Type)jcasType).casFeatCode_pubDate, jcasType.ll_cas.ll_getFSRef(v));}
1229247
void addMessageHandler(SubscriptionMessageHandler messageHandler)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "addMessageHandler", messageHandler);

    final boolean inserted = _subscriptionMessagePool.add(messageHandler);
    // If the message wasn't inserted, then the pool was exceeded
    if (!inserted)
      if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
        SibTr.debug(
          tc,
         "SubscriptionObjectPool size exceeded");

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "addMessageHandler");
  }
187435
public void setProvider(Object pObj) {

        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) {
            Tr.debug(tc, "setProvider pre: pObj(class)=" + pObj.getClass() + " isProxy=" + Proxy.isProxyClass(pObj.getClass()) + " provider=" + (provider==null?"null":provider.getClass()) + 
                            " oldProvider=" + (oldProvider==null?"null":oldProvider.getClass()));
        }

        this.oldProvider = this.provider;
        this.provider = (T) pObj;
        
        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) {
            Tr.debug(tc, "setProvider post: provider=" + (provider==null?"null":provider.getClass()) + 
                            " oldProvider=" + (oldProvider==null?"null":oldProvider.getClass()));
        }
    }
1036354
public <T extends EventListener> void subscribe(EventPublisher source, T listener) {
	if (source == null || listener == null) {
	    throw new IllegalArgumentException("Parameters cannot be null");
	}
	log.debug("[subscribe] Adding {} --> {}", source.getClass().getName(), listener.getClass().getName());

	GenericEventDispatcher<T> dispatcher = (GenericEventDispatcher<T>) dispatchers.get(source);
	if (dispatcher == null) {
	    log.warn("[subscribe] Registering with a disconnected source");
	    dispatcher = createDispatcher(source);
	}

	dispatcher.addListener(listener);

    }
730681
private <T> PubsubFuture<T> post(final String operation, final String path, final Object payload,
                                   final ResponseReader<T> responseReader) {
    return request(operation, HttpMethod.POST, path, payload, responseReader);
  }
857034
public void removePubSubOutputHandlerMatchTarget(
    ControllableProxySubscription sub)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "removePubSubOutputHandlerMatchTarget", sub);

    // Remove the PubSub OutputHandler from the matchspace
    try
    {
      removeTarget(sub);
    }
    catch (MatchingException e)
    {
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.matching.MessageProcessorMatching.removePubSubOutputHandlerMatchTarget",
        "1:1363:1.117.1.11",
        this);

      SibTr.exception(tc, e);
      SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
        new Object[] {
          "com.ibm.ws.sib.processor.matching.MessageProcessorMatching",
          "1:1370:1.117.1.11",
          e });

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "removePubSubOutputHandlerMatchTarget", "SICoreException");

      throw new SIErrorException(
        nls.getFormattedMessage(
          "INTERNAL_MESSAGING_ERROR_CWSIP0002",
          new Object[] {
            "com.ibm.ws.sib.processor.matching.MessageProcessorMatching",
            "1:1381:1.117.1.11",
            e },
          null),
        e);
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "removePubSubOutputHandlerMatchTarget");
  }
472813
@Override
    public void setSubscriptionDurability(final String subscriptionDurability) {
        if (TraceComponent.isAnyTracingEnabled() && TRACE.isDebugEnabled()) {
            SibTr.debug(this, TRACE, "setSubscriptionDurability",
                        subscriptionDurability);
        }
        _subscriptionDurability = subscriptionDurability;
    }
322162
public HashMap<SIBUuid8, PubSubOutputHandler> getAllPubSubOutputHandlers()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "getAllPubSubOutputHandlers");

        _pubsubOutputHandlerLockManager.lock();

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getAllPubSubOutputHandlers", _pubsubOutputHandlers);

        return _pubsubOutputHandlers;
    }