Package tigase.mongodb
Class MongoMsgBroadcastRepository
java.lang.Object
tigase.server.amp.db.MsgBroadcastRepository<org.bson.types.ObjectId,MongoDataSource>
tigase.mongodb.MongoMsgBroadcastRepository
- All Implemented Interfaces:
tigase.db.DataSourceAware<MongoDataSource>
public class MongoMsgBroadcastRepository
extends tigase.server.amp.db.MsgBroadcastRepository<org.bson.types.ObjectId,MongoDataSource>
Created by andrzej on 04.10.2016.
-
Nested Class Summary
Nested classes/interfaces inherited from class tigase.server.amp.db.MsgBroadcastRepository
tigase.server.amp.db.MsgBroadcastRepository.BroadcastMsg<T extends Object>, tigase.server.amp.db.MsgBroadcastRepository.MsgBroadcastRepositoryBean
-
Field Summary
Fields inherited from class tigase.server.amp.db.MsgBroadcastRepository
broadcastMessages, broadcastMessagesLastCleanup, parser
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
ensureBroadcastMessageRecipient
(String id, tigase.xmpp.jid.BareJID recipient) protected void
insertBroadcastMessage
(String id, tigase.xml.Element msg, Date expire, tigase.xmpp.jid.BareJID recipient) void
void
setDataSource
(MongoDataSource dataSource) Methods inherited from class tigase.server.amp.db.MsgBroadcastRepository
dumpBroadcastMessageKeys, getBroadcastMessages, getBroadcastMsg, updateBroadcastMessage
-
Constructor Details
-
MongoMsgBroadcastRepository
public MongoMsgBroadcastRepository()
-
-
Method Details
-
ensureBroadcastMessageRecipient
- Specified by:
ensureBroadcastMessageRecipient
in classtigase.server.amp.db.MsgBroadcastRepository<org.bson.types.ObjectId,
MongoDataSource>
-
insertBroadcastMessage
protected void insertBroadcastMessage(String id, tigase.xml.Element msg, Date expire, tigase.xmpp.jid.BareJID recipient) - Specified by:
insertBroadcastMessage
in classtigase.server.amp.db.MsgBroadcastRepository<org.bson.types.ObjectId,
MongoDataSource>
-
loadMessagesToBroadcast
public void loadMessagesToBroadcast()- Specified by:
loadMessagesToBroadcast
in classtigase.server.amp.db.MsgBroadcastRepository<org.bson.types.ObjectId,
MongoDataSource>
-
setDataSource
-