Package com.biglybt.plugin.net.buddy
Class BuddyPluginBuddyMessageHandler
- java.lang.Object
-
- com.biglybt.plugin.net.buddy.BuddyPluginBuddyMessageHandler
-
public class BuddyPluginBuddyMessageHandler extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private BuddyPluginBuddyMessage
active_message
private BuddyPluginBuddy
buddy
private java.util.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 java.io.File
store
-
Constructor Summary
Constructors Modifier Constructor Description protected
BuddyPluginBuddyMessageHandler(BuddyPluginBuddy _buddy, java.io.File _store)
-
Method Summary
All Methods Instance Methods Concrete Methods 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, java.util.Map content, int timeout_millis)
protected java.util.Map
readContent(java.lang.String target_str)
protected java.util.Map
readReply(BuddyPluginBuddyMessage message)
protected java.util.Map
readRequest(BuddyPluginBuddyMessage message)
void
removeListener(BuddyPluginBuddyMessageListener listener)
protected void
reportFailed(BuddyPluginBuddyMessage message, java.lang.Throwable cause, boolean do_subsequent)
protected void
reportFailedSupport(BuddyPluginBuddyMessage message, BuddyPluginException cause)
protected BuddyPluginBuddyMessage
restoreMessage(java.util.Map map)
java.util.List<BuddyPluginBuddyMessage>
retrieveExplicitMessages(int type)
protected void
saveConfig()
BuddyPluginBuddyMessage
storeExplicitMessage(int type, java.util.Map msg)
protected void
storeExplicitMessage(BuddyPluginBuddyMessage msg)
protected void
storeMessage(BuddyPluginBuddyMessage msg)
protected void
storeMessageSupport(BuddyPluginBuddyMessage msg, java.lang.String key)
protected void
writeContent(java.lang.String target_str, java.util.Map content)
protected void
writeReply(BuddyPluginBuddyMessage message, java.util.Map content)
protected void
writeRequest(BuddyPluginBuddyMessage message, java.util.Map content)
-
-
-
Field Detail
-
buddy
private BuddyPluginBuddy buddy
-
store
private java.io.File store
-
config_map
private java.util.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 Detail
-
BuddyPluginBuddyMessageHandler
protected BuddyPluginBuddyMessageHandler(BuddyPluginBuddy _buddy, java.io.File _store)
-
-
Method Detail
-
getBuddy
public BuddyPluginBuddy getBuddy()
-
queueMessage
public BuddyPluginBuddyMessage queueMessage(int subsystem, java.util.Map content, int timeout_millis) throws BuddyPluginException
- Throws:
BuddyPluginException
-
checkPersistentDispatch
protected void checkPersistentDispatch()
-
persistentDispatch
protected void persistentDispatch()
-
reportFailed
protected void reportFailed(BuddyPluginBuddyMessage message, java.lang.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, java.util.Map content) throws BuddyPluginException
- Throws:
BuddyPluginException
-
readRequest
protected java.util.Map readRequest(BuddyPluginBuddyMessage message) throws BuddyPluginException
- Throws:
BuddyPluginException
-
writeReply
protected void writeReply(BuddyPluginBuddyMessage message, java.util.Map content) throws BuddyPluginException
- Throws:
BuddyPluginException
-
readReply
protected java.util.Map readReply(BuddyPluginBuddyMessage message) throws BuddyPluginException
- Throws:
BuddyPluginException
-
writeContent
protected void writeContent(java.lang.String target_str, java.util.Map content) throws BuddyPluginException
- Throws:
BuddyPluginException
-
readContent
protected java.util.Map readContent(java.lang.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, java.util.Map msg)
-
retrieveExplicitMessages
public java.util.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, java.lang.String key) throws BuddyPluginException
- Throws:
BuddyPluginException
-
restoreMessage
protected BuddyPluginBuddyMessage restoreMessage(java.util.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)
-
-