tigase.server.amp

Class JDBCMsgRepository

java.lang.Object

tigase.server.amp.MsgRepository<Long>

tigase.server.amp.JDBCMsgRepository

All Implemented Interfaces:

MsgRepositoryIfc, Repository

public class JDBCMsgRepository
extends MsgRepository<Long>

Created: May 3, 2010 5:28:02 PM

Version:

$Rev$

Author:

Artur Hefczyc

Nested Class Summary

Nested classes/interfaces inherited from class tigase.server.amp.MsgRepository

MsgRepository.BroadcastMsg, MsgRepository.MsgDBItem

Nested classes/interfaces inherited from interface tigase.db.Repository

Repository.Meta

Field Summary

Fields inherited from class tigase.server.amp.MsgRepository

broadcastMessages, broadcastMessagesLastCleanup, earliestOffline, expiredQueue, MAX_QUEUE_SIZE, MSGS_STORE_LIMIT_KEY, MSGS_STORE_LIMIT_VAL, parser

Constructor Summary

Constructors

Constructor and Description
JDBCMsgRepository()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deleteMessage(Long msg_id)
protected void	ensureBroadcastMessageRecipient(String id, tigase.xmpp.BareJID recipient)
void	initRepository(String conn_str, Map<String,String> map) Method description
protected void	insertBroadcastMessage(String id, tigase.xml.Element msg, Date expire, tigase.xmpp.BareJID recipient)
protected void	loadExpiredQueue(Date expired)
protected void	loadExpiredQueue(int min_elements)
void	loadMessagesToBroadcast()
Queue<tigase.xml.Element>	loadMessagesToJID(tigase.xmpp.JID to, boolean delete) Method description
void	storeMessage(tigase.xmpp.JID from, tigase.xmpp.JID to, Date expired, tigase.xml.Element msg) Method description

Methods inherited from class tigase.server.amp.MsgRepository

dumpBroadcastMessageKeys, getBroadcastMessages, getBroadcastMsg, getInstance, getMessageExpired, getStanzaTo, updateBroadcastMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JDBCMsgRepository

public JDBCMsgRepository()

Method Detail

initRepository

public void initRepository(String conn_str,
                  Map<String,String> map)
                    throws DBInitException

Method description

Parameters:

conn_str -

map -

Throws:

SQLException

DBInitException - if there was an error during repository initialization. Some implementations, though, perform so called lazy initialization so even though there is a problem with the underlying repository it may not be signaled through this method call.

loadMessagesToJID

public Queue<tigase.xml.Element> loadMessagesToJID(tigase.xmpp.JID to,
                                          boolean delete)
                                            throws UserNotFoundException

Method description

Parameters:

to -

delete -

Returns:

a Queue of Element objects representing stored payloads for the given user's JID

Throws:

UserNotFoundException

storeMessage

public void storeMessage(tigase.xmpp.JID from,
                tigase.xmpp.JID to,
                Date expired,
                tigase.xml.Element msg)
                  throws UserNotFoundException

Method description

Parameters:

from -

to -

expired -

msg -

Throws:

UserNotFoundException

loadMessagesToBroadcast

public void loadMessagesToBroadcast()

Specified by:

loadMessagesToBroadcast in class MsgRepository<Long>

insertBroadcastMessage

protected void insertBroadcastMessage(String id,
                          tigase.xml.Element msg,
                          Date expire,
                          tigase.xmpp.BareJID recipient)

Specified by:

insertBroadcastMessage in class MsgRepository<Long>

ensureBroadcastMessageRecipient

protected void ensureBroadcastMessageRecipient(String id,
                                   tigase.xmpp.BareJID recipient)

Specified by:

ensureBroadcastMessageRecipient in class MsgRepository<Long>

deleteMessage

protected void deleteMessage(Long msg_id)

Specified by:

deleteMessage in class MsgRepository<Long>

loadExpiredQueue

protected void loadExpiredQueue(int min_elements)

Specified by:

loadExpiredQueue in class MsgRepository<Long>

loadExpiredQueue

protected void loadExpiredQueue(Date expired)

Specified by:

loadExpiredQueue in class MsgRepository<Long>