Examples of addTopic()


Examples of com.l2jfrozen.gameserver.communitybbs.BB.Forum.addtopic()

      }
      else
      {
        f.vload();
        Topic t = new Topic(Topic.ConstructorType.CREATE, TopicBBSManager.getInstance().getMaxID(f) + 1, Integer.parseInt(ar2), ar5, Calendar.getInstance().getTimeInMillis(), activeChar.getName(), activeChar.getObjectId(), Topic.MEMO, 0);
        f.addtopic(t);
        TopicBBSManager.getInstance().setMaxID(t.getID(), f);
        Post p = new Post(activeChar.getName(), activeChar.getObjectId(), Calendar.getInstance().getTimeInMillis(), t.getID(), f.getID(), ar4);
        PostBBSManager.getInstance().addPostByTopic(p, t);
        parsecmd("_bbsmemo", activeChar);
        t = null;
View Full Code Here

Examples of com.qq.open.qzone.topic.QqAddTopic.addTopic()

    qatb.setLbsNm("辽宁大连");
   
   
    QqAddTopic qqAddTopic = new QqAddTopic();
   
    qqAddTopic.addTopic(qatb);
    System.exit(0);
  }
}
View Full Code Here

Examples of com.taobao.metamorphosis.server.utils.MetaConfig.addTopic()

    public void init(final MetaMorphosisBroker metaMorphosisBroker, final Properties props) {
        final MetaConfig metaConfig = metaMorphosisBroker.getMetaConfig();
        // Added slave status topic for master to check it.
        TopicConfig topicConfig = new TopicConfig(Constants.TEST_SLAVE_TOPIC, metaConfig);
        topicConfig.setNumPartitions(1);
        metaConfig.addTopic(Constants.TEST_SLAVE_TOPIC, topicConfig);
        // slave��ע�ᵽzk,ǿ��
        metaMorphosisBroker.getBrokerZooKeeper().getZkConfig().zkEnable = false;
        this.orderedPutExecutor =
                new OrderedThreadPoolExecutor(metaConfig.getPutProcessThreadCount(),
                    metaConfig.getPutProcessThreadCount(), 60, TimeUnit.SECONDS, new NamedThreadFactory("putProcessor"));
View Full Code Here

Examples of net.sf.l2j.gameserver.communitybbs.BB.Forum.addtopic()

        Topic t = new Topic(Topic.ConstructorType.CREATE,
                  TopicBBSManager.getInstance().getMaxID(f) + 1,
                  Integer.parseInt(ar2), ar5,
                  Calendar.getInstance().getTimeInMillis(), activeChar.getName(),
                  activeChar.getObjectId(), Topic.MEMO, 0);
        f.addtopic(t);
        TopicBBSManager.getInstance().setMaxID(t.getID(), f);
        Post p = new Post(activeChar.getName(), activeChar.getObjectId(),
                  Calendar.getInstance().getTimeInMillis(), t.getID(), f.getID(), ar4);
        PostBBSManager.getInstance().addPostByTopic(p, t);
        parsecmd("_bbsmemo", activeChar);
View Full Code Here

Examples of org.apache.activemq.broker.jmx.BrokerViewMBean.addTopic()

                    if (it.hasNext()) {
                        ObjectInstance instance = (ObjectInstance) it.next();
                        brokerObj = instance.getObjectName();
                    }
                    BrokerViewMBean brokerMBean = (BrokerViewMBean) MBeanServerInvocationHandler.newProxyInstance(server, brokerObj, BrokerViewMBean.class, true);
                    brokerMBean.addTopic(destinationInfo.getPhysicalName());
                }
                proxy = (DestinationViewMBean) MBeanServerInvocationHandler.newProxyInstance(server, objName, TopicViewMBean.class, true);
            }
            stat.setConsumerCount(proxy.getConsumerCount());
            stat.setEnqueueCount(proxy.getEnqueueCount());
View Full Code Here

Examples of org.apache.activemq.broker.jmx.BrokerViewMBean.addTopic()

                    if (it.hasNext()) {
                        ObjectInstance instance = (ObjectInstance) it.next();
                        brokerObj = instance.getObjectName();
                    }
                    BrokerViewMBean brokerMBean = (BrokerViewMBean) MBeanServerInvocationHandler.newProxyInstance(server, brokerObj, BrokerViewMBean.class, true);
                    brokerMBean.addTopic(destinationInfo.getPhysicalName());
                }
                proxy = (DestinationViewMBean) MBeanServerInvocationHandler.newProxyInstance(server, objName, TopicViewMBean.class, true);
            }
            stat.setConsumerCount(proxy.getConsumerCount());
            stat.setEnqueueCount(proxy.getEnqueueCount());
View Full Code Here

Examples of org.apache.muse.ws.notification.NotificationProducer.addTopic()

        // initialize the advertisement topics
        //
        NotificationProducer wsn =
            (NotificationProducer)resource.getCapability(WsnConstants.PRODUCER_URI);
       
        wsn.addTopic(MuwsConstants.ADV_ME_CREATION_TOPIC);
        wsn.addTopic(MuwsConstants.ADV_ME_DESTRUCTION_TOPIC);
       
        //
        // create subscriptions for all event consumer that are going to
        // receive notifications from the above topics
View Full Code Here

Examples of org.apache.ws.notification.topics.Topic.addTopic()

      TopicSpace topicSpace0 = m_topicSpaceSet.addTopicSpace( new TopicSpaceImpl( "" ) );
      topicSpace0.addTopic( "celebs" );
      TopicSpace topicSpace1 = m_topicSpaceSet.addTopicSpace( new TopicSpaceImpl( NSURI1 ) );
      Topic      sportsTopic = topicSpace1.addTopic( "sports" );
      Topic      tennisTopic = sportsTopic.addTopic( "tennis" );
      tennisTopic.addTopic( "college" );
      Topic footballTopic = sportsTopic.addTopic( "football" );
      footballTopic.addTopic( "college" );
      Topic gamesTopic = topicSpace1.addTopic( "games" );
      gamesTopic.addTopic( "monopoly" );
      gamesTopic.addTopic( "chess" );
View Full Code Here

Examples of org.apache.ws.notification.topics.Topic.addTopic()

      TopicSpace topicSpace1 = m_topicSpaceSet.addTopicSpace( new TopicSpaceImpl( NSURI1 ) );
      Topic      sportsTopic = topicSpace1.addTopic( "sports" );
      Topic      tennisTopic = sportsTopic.addTopic( "tennis" );
      tennisTopic.addTopic( "college" );
      Topic footballTopic = sportsTopic.addTopic( "football" );
      footballTopic.addTopic( "college" );
      Topic gamesTopic = topicSpace1.addTopic( "games" );
      gamesTopic.addTopic( "monopoly" );
      gamesTopic.addTopic( "chess" );
      TopicSpace topicSpace2 = m_topicSpaceSet.addTopicSpace( new TopicSpaceImpl( NSURI2 ) );
      Topic      bandsTopic = topicSpace2.addTopic( "bands" );
View Full Code Here

Examples of org.apache.ws.notification.topics.Topic.addTopic()

      Topic      tennisTopic = sportsTopic.addTopic( "tennis" );
      tennisTopic.addTopic( "college" );
      Topic footballTopic = sportsTopic.addTopic( "football" );
      footballTopic.addTopic( "college" );
      Topic gamesTopic = topicSpace1.addTopic( "games" );
      gamesTopic.addTopic( "monopoly" );
      gamesTopic.addTopic( "chess" );
      TopicSpace topicSpace2 = m_topicSpaceSet.addTopicSpace( new TopicSpaceImpl( NSURI2 ) );
      Topic      bandsTopic = topicSpace2.addTopic( "bands" );
      bandsTopic.addTopic( "beatles" );
      bandsTopic.addTopic( "kinks" );
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.