Package com.biglybt.plugin.net.buddy
Class BuddyPluginBuddyMessageHandler
java.lang.Object
com.biglybt.plugin.net.buddy.BuddyPluginBuddyMessageHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate BuddyPluginBuddyMessage
private BuddyPluginBuddy
private Map
private long
private long
private CopyOnWriteList
private int
private int
private int
private File
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
BuddyPluginBuddyMessageHandler
(BuddyPluginBuddy _buddy, File _store) -
Method Summary
Modifier and TypeMethodDescriptionvoid
addListener
(BuddyPluginBuddyMessageListener listener) protected void
protected void
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()
getBuddy()
int
protected void
protected void
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
protected void
reportFailed
(BuddyPluginBuddyMessage message, Throwable cause, boolean do_subsequent) protected void
reportFailedSupport
(BuddyPluginBuddyMessage message, BuddyPluginException cause) protected BuddyPluginBuddyMessage
restoreMessage
(Map map) retrieveExplicitMessages
(int type) protected void
storeExplicitMessage
(int type, Map msg) protected void
protected void
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)
-
Field Details
-
buddy
-
store
-
config_map
-
message_count
private int message_count -
pending_deletes
private int pending_deletes -
next_message_id
private int next_message_id -
listeners
-
active_message
-
last_failure
private long last_failure -
last_pending_success
private long last_pending_success
-
-
Constructor Details
-
BuddyPluginBuddyMessageHandler
-
-
Method Details
-
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
-
checkPendingSuccess
protected void checkPendingSuccess() -
getMessageCount
public int getMessageCount() -
deleteMessage
-
destroy
protected void destroy() -
writeRequest
protected void writeRequest(BuddyPluginBuddyMessage message, Map content) throws BuddyPluginException - Throws:
BuddyPluginException
-
readRequest
- Throws:
BuddyPluginException
-
writeReply
- Throws:
BuddyPluginException
-
readReply
- Throws:
BuddyPluginException
-
writeContent
- Throws:
BuddyPluginException
-
readContent
- Throws:
BuddyPluginException
-
deleteRequest
-
deleteRequest
protected void deleteRequest(int id) -
deleteReply
-
deleteReply
protected void deleteReply(int id) -
storeExplicitMessage
-
retrieveExplicitMessages
-
storeExplicitMessage
- Throws:
BuddyPluginException
-
storeMessage
- Throws:
BuddyPluginException
-
storeMessageSupport
protected void storeMessageSupport(BuddyPluginBuddyMessage msg, String key) throws BuddyPluginException - Throws:
BuddyPluginException
-
restoreMessage
- Throws:
BuddyPluginException
-
loadConfig
protected void loadConfig() -
saveConfig
- Throws:
BuddyPluginException
-
addListener
-
removeListener
-