Package com.biglybt.core.messenger
Class PlatformMessenger
- java.lang.Object
-
- com.biglybt.core.messenger.PlatformMessenger
-
public class PlatformMessenger extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
PlatformMessenger.fakeContext
-
Field Summary
Fields Modifier and Type Field Description private static boolean
allowMulti
private static PlatformMessenger.fakeContext
context
private static boolean
DEBUG_URL
private static AsyncDispatcher
dispatcher
private static boolean
initialized
private static java.util.Map<java.lang.String,java.lang.Object>
mapExtra
(package private) static java.util.Map<java.lang.String,java.util.Map<PlatformMessage,PlatformMessengerListener>>
mapQueues
Key: id of queue; Value: Map of queued messages & listeners(package private) static java.util.Map<java.lang.String,TimerEvent>
mapTimerEvents
private static int
MAX_POST_LENGTH
(package private) static AEMonitor
mon_mapTimerEvents
private static AEMonitor
queue_mon
private static java.lang.String
QUEUE_NOAZID
private static java.lang.String
QUEUE_NORMAL
static java.lang.String
REPLY_ACTION
static java.lang.String
REPLY_EXCEPTION
static java.lang.String
REPLY_RESULT
private static Timer
timerProcess
private static java.lang.String
URL_PLATFORM_MESSAGE
private static java.lang.String
URL_POST_PLATFORM_DATA
private static boolean
USE_HTTP_POST
-
Constructor Summary
Constructors Constructor Description PlatformMessenger()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
addExtraParam(java.lang.String key, java.lang.Object value)
static void
debug(java.lang.String string)
protected static void
debug(java.lang.String string, java.lang.Throwable e)
private static java.lang.Object[]
downloadURL(java.net.URL rpc_url, java.lang.String postData, boolean forceProxy)
private static java.lang.Object[]
downloadURLSupport(java.net.Proxy proxy, java.lang.String proxy_host, java.net.URL url, java.lang.String postData)
static boolean
getAllowMulti()
static ClientMessageContext
getClientMessageContext()
static void
init()
protected static void
processQueue(java.lang.String queueID, java.util.Map mapQueue)
protected static void
processQueueAsync(java.lang.String sURL, java.lang.String sData, java.util.Map mapProcessing, boolean forceProxy)
static void
pushMessageNow(PlatformMessage message, PlatformMessengerListener listener)
Sends the message almost immediately, skipping delayauthorization checkstatic void
queueMessage(PlatformMessage message, PlatformMessengerListener listener)
static void
queueMessage(PlatformMessage message, PlatformMessengerListener listener, boolean addToBottom)
static void
setAllowMulti(boolean allowMulti)
-
-
-
Field Detail
-
DEBUG_URL
private static final boolean DEBUG_URL
-
URL_PLATFORM_MESSAGE
private static final java.lang.String URL_PLATFORM_MESSAGE
- See Also:
- Constant Field Values
-
URL_POST_PLATFORM_DATA
private static final java.lang.String URL_POST_PLATFORM_DATA
- See Also:
- Constant Field Values
-
MAX_POST_LENGTH
private static final int MAX_POST_LENGTH
- See Also:
- Constant Field Values
-
USE_HTTP_POST
private static boolean USE_HTTP_POST
-
REPLY_EXCEPTION
public static java.lang.String REPLY_EXCEPTION
-
REPLY_ACTION
public static java.lang.String REPLY_ACTION
-
REPLY_RESULT
public static java.lang.String REPLY_RESULT
-
mapQueues
static java.util.Map<java.lang.String,java.util.Map<PlatformMessage,PlatformMessengerListener>> mapQueues
Key: id of queue; Value: Map of queued messages & listeners
-
QUEUE_NOAZID
private static final java.lang.String QUEUE_NOAZID
- See Also:
- Constant Field Values
-
QUEUE_NORMAL
private static final java.lang.String QUEUE_NORMAL
- See Also:
- Constant Field Values
-
queue_mon
private static AEMonitor queue_mon
-
timerProcess
private static Timer timerProcess
-
mapTimerEvents
static java.util.Map<java.lang.String,TimerEvent> mapTimerEvents
-
mon_mapTimerEvents
static AEMonitor mon_mapTimerEvents
-
initialized
private static boolean initialized
-
context
private static PlatformMessenger.fakeContext context
-
allowMulti
private static boolean allowMulti
-
dispatcher
private static AsyncDispatcher dispatcher
-
mapExtra
private static java.util.Map<java.lang.String,java.lang.Object> mapExtra
-
-
Method Detail
-
init
public static void init()
-
getClientMessageContext
public static ClientMessageContext getClientMessageContext()
-
queueMessage
public static void queueMessage(PlatformMessage message, PlatformMessengerListener listener)
-
queueMessage
public static void queueMessage(PlatformMessage message, PlatformMessengerListener listener, boolean addToBottom)
-
debug
public static void debug(java.lang.String string)
- Parameters:
string
-
-
debug
protected static void debug(java.lang.String string, java.lang.Throwable e)
-
pushMessageNow
public static void pushMessageNow(PlatformMessage message, PlatformMessengerListener listener)
Sends the message almost immediately, skipping delayauthorization check- Parameters:
message
-listener
-- Since:
- 3.0.5.3
-
processQueue
protected static void processQueue(java.lang.String queueID, java.util.Map mapQueue)
-
processQueueAsync
protected static void processQueueAsync(java.lang.String sURL, java.lang.String sData, java.util.Map mapProcessing, boolean forceProxy) throws java.lang.Throwable
- Parameters:
mapProcessing
-- Throws:
java.lang.Exception
java.lang.Throwable
-
downloadURL
private static java.lang.Object[] downloadURL(java.net.URL rpc_url, java.lang.String postData, boolean forceProxy) throws java.lang.Throwable
- Throws:
java.lang.Throwable
-
downloadURLSupport
private static java.lang.Object[] downloadURLSupport(java.net.Proxy proxy, java.lang.String proxy_host, java.net.URL url, java.lang.String postData) throws java.lang.Throwable
- Throws:
java.lang.Throwable
-
setAllowMulti
public static void setAllowMulti(boolean allowMulti)
-
getAllowMulti
public static boolean getAllowMulti()
-
addExtraParam
public static void addExtraParam(java.lang.String key, java.lang.Object value)
-
-