Class BuddyPluginBuddyMessageHandler

java.lang.Object

com.biglybt.plugin.net.buddy.BuddyPluginBuddyMessageHandler

public class BuddyPluginBuddyMessageHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private BuddyPluginBuddyMessage	active_message
private BuddyPluginBuddy	buddy
private Map	config_map
private long	last_failure
private long	last_pending_success
private CopyOnWriteList	listeners
private int	message_count
private int	next_message_id
private int	pending_deletes
private File	store

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BuddyPluginBuddyMessageHandler(BuddyPluginBuddy _buddy, File _store)

Method Summary

Modifier and Type	Method	Description
void	addListener(BuddyPluginBuddyMessageListener listener)
protected void	checkPendingSuccess()
protected void	checkPersistentDispatch()
protected void	deleteMessage(BuddyPluginBuddyMessage message)
protected void	deleteReply(int id)
protected void	deleteReply(BuddyPluginBuddyMessage message)
protected void	deleteRequest(int id)
protected void	deleteRequest(BuddyPluginBuddyMessage message)
protected void	destroy()
BuddyPluginBuddy	getBuddy()
int	getMessageCount()
protected void	loadConfig()
protected void	persistentDispatch()
BuddyPluginBuddyMessage	queueMessage(int subsystem, Map content, int timeout_millis)
protected Map	readContent(String target_str)
protected Map	readReply(BuddyPluginBuddyMessage message)
protected Map	readRequest(BuddyPluginBuddyMessage message)
void	removeListener(BuddyPluginBuddyMessageListener listener)
protected void	reportFailed(BuddyPluginBuddyMessage message, Throwable cause, boolean do_subsequent)
protected void	reportFailedSupport(BuddyPluginBuddyMessage message, BuddyPluginException cause)
protected BuddyPluginBuddyMessage	restoreMessage(Map map)
List<BuddyPluginBuddyMessage>	retrieveExplicitMessages(int type)
protected void	saveConfig()
BuddyPluginBuddyMessage	storeExplicitMessage(int type, Map msg)
protected void	storeExplicitMessage(BuddyPluginBuddyMessage msg)
protected void	storeMessage(BuddyPluginBuddyMessage msg)
protected void	storeMessageSupport(BuddyPluginBuddyMessage msg, String key)
protected void	writeContent(String target_str, Map content)
protected void	writeReply(BuddyPluginBuddyMessage message, Map content)
protected void	writeRequest(BuddyPluginBuddyMessage message, Map content)

Methods inherited from class Object

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

Field Details

buddy

private BuddyPluginBuddy buddy

store

private File store

config_map

private Map config_map

message_count

private int message_count

pending_deletes

private int pending_deletes

next_message_id

private int next_message_id

listeners

private CopyOnWriteList listeners

active_message

private BuddyPluginBuddyMessage active_message

last_failure

private long last_failure

last_pending_success

private long last_pending_success

Constructor Details

BuddyPluginBuddyMessageHandler

protected BuddyPluginBuddyMessageHandler(BuddyPluginBuddy _buddy,
 File _store)

Method Details

getBuddy

public BuddyPluginBuddy getBuddy()

queueMessage

public BuddyPluginBuddyMessage queueMessage(int subsystem,
 Map content,
 int timeout_millis)
                                     throws BuddyPluginException

Throws:

BuddyPluginException

checkPersistentDispatch

protected void checkPersistentDispatch()

persistentDispatch

protected void persistentDispatch()

reportFailed

protected void reportFailed(BuddyPluginBuddyMessage message,
 Throwable cause,
 boolean do_subsequent)

reportFailedSupport

protected void reportFailedSupport(BuddyPluginBuddyMessage message,
 BuddyPluginException cause)

checkPendingSuccess

protected void checkPendingSuccess()

getMessageCount

public int getMessageCount()

deleteMessage

protected void deleteMessage(BuddyPluginBuddyMessage message)

destroy

protected void destroy()

writeRequest

protected void writeRequest(BuddyPluginBuddyMessage message,
 Map content)
                     throws BuddyPluginException

Throws:

BuddyPluginException

readRequest

protected Map readRequest(BuddyPluginBuddyMessage message)
                   throws BuddyPluginException

Throws:

BuddyPluginException

writeReply

protected void writeReply(BuddyPluginBuddyMessage message,
 Map content)
                   throws BuddyPluginException

Throws:

BuddyPluginException

readReply

protected Map readReply(BuddyPluginBuddyMessage message)
                 throws BuddyPluginException

Throws:

BuddyPluginException

writeContent

protected void writeContent(String target_str,
 Map content)
                     throws BuddyPluginException

Throws:

BuddyPluginException

readContent

protected Map readContent(String target_str)
                   throws BuddyPluginException

Throws:

BuddyPluginException

deleteRequest

protected void deleteRequest(BuddyPluginBuddyMessage message)

deleteRequest

protected void deleteRequest(int id)

deleteReply

protected void deleteReply(BuddyPluginBuddyMessage message)

deleteReply

protected void deleteReply(int id)

storeExplicitMessage

public BuddyPluginBuddyMessage storeExplicitMessage(int type,
 Map msg)

retrieveExplicitMessages

public List<BuddyPluginBuddyMessage> retrieveExplicitMessages(int type)

storeExplicitMessage

protected void storeExplicitMessage(BuddyPluginBuddyMessage msg)
                             throws BuddyPluginException

Throws:

BuddyPluginException

storeMessage

protected void storeMessage(BuddyPluginBuddyMessage msg)
                     throws BuddyPluginException

Throws:

BuddyPluginException

storeMessageSupport

protected void storeMessageSupport(BuddyPluginBuddyMessage msg,
 String key)
                            throws BuddyPluginException

Throws:

BuddyPluginException

restoreMessage

protected BuddyPluginBuddyMessage restoreMessage(Map map)
                                          throws BuddyPluginException

Throws:

BuddyPluginException

loadConfig

protected void loadConfig()

saveConfig

protected void saveConfig()
                   throws BuddyPluginException

Throws:

BuddyPluginException

addListener

public void addListener(BuddyPluginBuddyMessageListener listener)

removeListener

public void removeListener(BuddyPluginBuddyMessageListener listener)