本文整理汇总了Java中org.jivesoftware.smackx.pubsub.PubSubManager类的典型用法代码示例。如果您正苦于以下问题:Java PubSubManager类的具体用法?Java PubSubManager怎么用?Java PubSubManager使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PubSubManager类属于org.jivesoftware.smackx.pubsub包,在下文中一共展示了PubSubManager类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createNodeToAllowComments
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
public void createNodeToAllowComments(String blogPostId) {
String nodeName = PublishCommentExtension.NODE + "/" + blogPostId;
PubSubManager pubSubManager = PubSubManager.getInstance(XMPPSession.getInstance().getXMPPConnection());
try {
// create node
ConfigureForm configureForm = new ConfigureForm(DataForm.Type.submit);
configureForm.setPublishModel(PublishModel.open);
configureForm.setAccessModel(AccessModel.open);
Node node = pubSubManager.createNode(nodeName, configureForm);
// subscribe to comments
String myJIDString = getUser().toString();
node.subscribe(myJIDString);
} catch (SmackException.NoResponseException | XMPPException.XMPPErrorException | SmackException.NotConnectedException | InterruptedException e) {
e.printStackTrace();
}
}
开发者ID:esl,项目名称:mangosta-android,代码行数:19,代码来源:XMPPSession.java
示例2: getRandomPubnode
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
protected LeafNode getRandomPubnode(PubSubManager pubMgr, boolean persistItems, boolean deliverPayload) throws XMPPException
{
ConfigureForm form = new ConfigureForm(FormType.submit);
form.setPersistentItems(persistItems);
form.setDeliverPayloads(deliverPayload);
form.setAccessModel(AccessModel.open);
return (LeafNode)pubMgr.createNode("/test/Pubnode" + System.currentTimeMillis(), form);
}
开发者ID:TTalkIM,项目名称:Smack,代码行数:9,代码来源:PubSubTestCase.java
示例3: getManager
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
protected PubSubManager getManager(int idx)
{
if (manager == null)
{
manager = new PubSubManager[getMaxConnections()];
for(int i=0; i<manager.length; i++)
{
manager[i] = new PubSubManager(getConnection(i), getService());
}
}
return manager[idx];
}
开发者ID:TTalkIM,项目名称:Smack,代码行数:14,代码来源:PubSubTestCase.java
示例4: DataHandler
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
/**
* Creates a new data handler.
* @param connectionHandler The connection handler to be used for requests.
* @param spaceHandler An instance of a space handler to be used for requesting space properties.
*/
public DataHandler(ConnectionHandler connectionHandler, SpaceHandler spaceHandler){
if (connectionHandler == null || spaceHandler == null){
throw new IllegalArgumentException("None of the Arguments may be null");
}
this.connectionHandler = connectionHandler;
this.isConnectionResetted = true;
this.spaceHandler = spaceHandler;
this.timeout = connectionHandler.getConfiguration().requestTimeout();
this.userWantedMode = Mode.OFFLINE;
this.connection = this.connectionHandler.getXMPPConnection();
this.listeners = new ArrayList<DataObjectListener>();
this.handledSpaces = new ArrayList<Space>();
this.datawrapper = DataWrapper.getInstance();
this.pendingPayloadRequests = new HashMap<String, RequestFuture<List<PayloadItem<SimplePayload>>>>();
this.pendingPublishingRequests = new HashMap<String, RequestFuture<IQ>>();
this.pendingPersistenceServiceQueries = new HashMap<String, RequestFuture<IQ>>();
this.userInfo = this.connectionHandler.getCurrentUser();
this.dataObjectFilter = null;
this.publishIdMap = new HashMap<String, String>();
this.pubsubServiceListeners = new HashMap<String, PacketListener>();
this.persistenceServiceListeners = new HashMap<String, PacketListener>();
this.pubsubManagers = new HashMap<String, PubSubManager>();
setPubSubPacketInterceptor();
setConnectionStatusListener();
}
开发者ID:MirrorIP,项目名称:msf-spaces-sdk-android,代码行数:36,代码来源:DataHandler.java
示例5: getNode
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
/**
* Retrieves a pubsub node from the pubsub service.
* @param nodeId The id of the node to retrieve.
* @param pubsubService JID of the pubsub service component handling the the node.
* @return The pubsub node.
* @throws UnknownEntityException No node with the given ID exists.
*/
protected Node getNode(String nodeId, String pubsubService) throws UnknownEntityException {
if (!pubsubManagers.containsKey(pubsubService)) {
registerPubsubService(pubsubService);
}
PubSubManager manager = pubsubManagers.get(pubsubService);
try {
return manager.getNode(nodeId);
} catch(XMPPException e){
throw new UnknownEntityException("The node " + nodeId + " couldn't be retrieved.", e);
}
}
开发者ID:MirrorIP,项目名称:msf-spaces-sdk-android,代码行数:20,代码来源:DataHandler.java
示例6: getPubSubManager
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
public PubSubManager getPubSubManager() {
EntityBareJid myJIDString = getUser();
return PubSubManager.getInstance(mXMPPConnection, myJIDString);
}
开发者ID:esl,项目名称:mangosta-android,代码行数:5,代码来源:XMPPSession.java
示例7: getPubSubService
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
public Jid getPubSubService() throws XMPPException.XMPPErrorException, SmackException.NotConnectedException, InterruptedException, SmackException.NoResponseException {
return PubSubManager.getPubSubService(getXMPPConnection());
}
开发者ID:esl,项目名称:mangosta-android,代码行数:4,代码来源:XMPPSession.java
示例8: getManager
import org.jivesoftware.smackx.pubsub.PubSubManager; //导入依赖的package包/类
protected PubSubManager getManager()
{
return getManager(0);
}
开发者ID:TTalkIM,项目名称:Smack,代码行数:5,代码来源:SingleUserTestCase.java
注:本文中的org.jivesoftware.smackx.pubsub.PubSubManager类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论