code: private void createInputHandlersForPubSub()
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "createInputHandlersForPubSub");
  
          // Create the pub-sub input handler.
          _baseDestinationHandler.setInputHandler(
                          new PubSubInputHandler(
                                          _baseDestinationHandler,
                                          _pubSubRemoteSupport.getTargetProtocolItemStream(),
                                          _pubsubMessageItemStream,
                                          _proxyReferenceStream,
                                          _pubSubRemoteSupport.getSourceProtocolItemStream()));
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "createInputHandlersForPubSub");
      }
docs: Method createInputHandlersForPubSub.
  <p>Create the PubSub and preMediated InputHandlers.</p>