Set the list of topics to be associated with the specified work stage.

@param stageName
the work stage name
@param topics
the topics associated with the work stage
963506
synchronized void setStageTopics(String stageName, String[] topics) {
        for (String t : topics) {
            if (t.equals("*")) {
                wildcardStageTopics.put("", stageName);
            } else if (t.endsWith("/*")) {
                wildcardStageTopics.put(t.substring(0, t.length() - 1), stageName);
            } else {
                discreteStageTopics.put(t, stageName);
            }
        }

        // Clear the cache since it's no longer up to date
        clearTopicDataCache();
    }
105147
public CMAWebhook addTopic(CMAWebhookTopic topic) {
    if (this.topics == null) {
      this.topics = new ArrayList<CMAWebhookTopic>();
    }

    this.topics.add(topic);
    return this;
  }
824384
@com.fasterxml.jackson.annotation.JsonProperty("clusterName")
    public void setClusterName(String clusterName) {
        this.clusterName = clusterName;
    }
1066549
@Override
    public java.util.concurrent.Future<ListSubscriptionsByTopicResult> listSubscriptionsByTopicAsync(String topicArn) {

        return listSubscriptionsByTopicAsync(new ListSubscriptionsByTopicRequest().withTopicArn(topicArn));
    }
833929
public void pushMessages(List<Pair<K, V>> messages) {
    for (Pair<K, V> message: messages) {
      this.producer.send(new ProducerRecord<>(topic, message.getKey(), message.getValue()), (recordMetadata, e) -> {
        if (e != null) {
          log.error("Failed to send message to topic {} due to exception: ", topic, e);
        }
      });
    }
  }
149222
@Override
    public void addAction(final LifecycleStage stage, final LifecycleAction<T> action)
    {
        stageEvents.add(new StageEvent(stage, action));
    }
6646
public void setSections(final List<Section> SECTIONS) {
        sections.setAll(SECTIONS);
        Collections.sort(sections, new SectionComparator());
        fireUpdateEvent(SECTION_EVENT);
    }
365767
protected function addStageToConfiguration(string $stageName, array $sections)
    {
        $stage = new Stage($stageName);

        foreach ($this->filterSections($sections) as $sectionName => $commands) {
            $stage->addSection($this->buildSection($sectionName, $commands));
        }

        $this->configuration->setStage($stage);
    }
236255
protected void setNames(Set<String> names)
   {
      this.names.clear();
      this.indexes.clear();
      this.names.addAll(names);
      this.indexes.addAll(names);
      // new list of indexes if thought to be up to date
      dirty = false;
   }
292520
def list_topics(region=None, key=None, keyid=None, profile=None):
    '''
    
    '''
    conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
    res = {}
    NextToken = ''
    while NextToken is not None:
        ret = conn.list_topics(NextToken=NextToken)
        NextToken = ret.get('NextToken', None)
        arns = jmespath.search('Topics[*].TopicArn', ret)
        for t in arns:
            short_name = t.split(':')[-1]
            res[short_name] = t
    return res
929857
public static void addActors(final Stage stage, final Iterable<Actor> actors) {
        if (actors != null) {
            for (final Actor actor : actors) {
                stage.addActor(actor);
            }
        }
    }
228284
void removeRegistrations(String topic) {
        Collection<Registration> all = registrations.remove(topic);
        if (all == null) {
            return;
        }
        for (Registration reg : all) {
            registrationIdMap.remove(reg.getId());
            pingNotifiableEventListener(topic, reg, false);
        }
    }
310552
public void setTopic(String topic)
  {
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "setTopic", topic);

    this.topic = topic;

    if (tc.isEntryEnabled())
      SibTr.exit(tc, "setTopic");
  }
162373
public void setItems(java.util.Collection<Stage> items) {
        if (items == null) {
            this.items = null;
            return;
        }

        this.items = new java.util.ArrayList<Stage>(items);
    }
1011529
public void setTopicIds(String v) {
    if (Token_Type.featOkTst && ((Token_Type)jcasType).casFeat_topicIds == null)
      jcasType.jcas.throwFeatMissing("topicIds", "de.julielab.jules.types.Token");
    jcasType.ll_cas.ll_setStringValue(addr, ((Token_Type)jcasType).casFeatCode_topicIds, v);}
1107790
public void info(UserFeedbackEvent.Stage stage, String message) {
    Log.info(stage+": "+message);
    addEvent(new UserFeedbackEvent(autoML, UserFeedbackEvent.Level.Info, stage, message));
  }
425895
public void clearTopics()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "clearTopics");
    
    //we only clear the topics if the remote me
    //has subscribed to some topics on this me.
    if(_outputHandler!=null)
    {
      if (_outputHandler.getTopics() != null)
      {
        Iterator topics = 
          Arrays.asList(_outputHandler.getTopics()).iterator();

        LinkedList topicSpaces = new LinkedList();
        LinkedList topicSpaceMappings = new LinkedList();
        // Iterate through each of the topics and add the matching ts uuid and ts mapping
        for (int i = 0; i < _outputHandler.getTopics().length; i++)
        {
          topicSpaces.add(_outputHandler.getTopicSpaceUuid().toString());   
          topicSpaceMappings.add(_outputHandler.getTopicSpaceMapping());         
        }
  
        //get the NeighbourProxyListener
        NeighbourProxyListener listener = 
          _messageProcessor.getProxyHandler().getProxyListener();
        try
        {
          ExternalAutoCommitTransaction tran =
            _messageProcessor.getTXManager().createAutoCommitTransaction();
          listener.deleteProxySubscription(topics,
                                           topicSpaces.iterator(),
                                           topicSpaceMappings.iterator(),
                                           _outputHandler.getTargetMEUuid(),
                                           _outputHandler.getBusName(),
                                           tran);
        }
        catch(SIResourceException e)
        {
          FFDCFilter.processException(
            e,
            "com.ibm.ws.sib.processor.runtime.RemoteTopicSpaceControl.clearTopics",
            "1:456:1.34",
            this);
            
          SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
            new Object[] { "com.ibm.ws.sib.processor.runtime.RemoteTopicSpaceControl.clearTopics", 
                           "1:461:1.34", 
                           SIMPUtils.getStackTrace(e) });
          SibTr.exception(tc, e);
        }
      }
      else
      {
        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
          SibTr.debug(tc, "No Topics to delete for topicspace with id " + _outputHandler.getDestinationName());
      }
    }//end if PSOH==null

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "clearTopics");        
  }