Class PlatformMessenger

java.lang.Object

com.biglybt.core.messenger.PlatformMessenger

public class PlatformMessenger
extends 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 final boolean	DEBUG_URL
private static AsyncDispatcher	dispatcher
private static boolean	initialized
private static Map<String,Object>	mapExtra
(package private) static Map<String, Map<PlatformMessage, PlatformMessengerListener>>	mapQueues	Key: id of queue; Value: Map of queued messages invalid input: '&' listeners
(package private) static Map<String, TimerEvent>	mapTimerEvents
private static final int	MAX_POST_LENGTH
(package private) static AEMonitor	mon_mapTimerEvents
private static AEMonitor	queue_mon
private static final String	QUEUE_NOAZID
private static final String	QUEUE_NORMAL
static String	REPLY_ACTION
static String	REPLY_EXCEPTION
static String	REPLY_RESULT
private static Timer	timerProcess
private static final String	URL_PLATFORM_MESSAGE
private static final String	URL_POST_PLATFORM_DATA
private static boolean	USE_HTTP_POST

Constructor Summary

Constructors

Constructor	Description
PlatformMessenger()

Method Summary

Modifier and Type	Method	Description
static void	addExtraParam(String key, Object value)
static void	debug(String string)
protected static void	debug(String string, Throwable e)
private static Object[]	downloadURL(URL rpc_url, String postData, boolean forceProxy)
private static Object[]	downloadURLSupport(Proxy proxy, String proxy_host, URL url, String postData)
static boolean	getAllowMulti()
static ClientMessageContext	getClientMessageContext()
static void	init()
protected static void	processQueue(String queueID, Map mapQueue)
protected static void	processQueueAsync(String sURL, String sData, Map mapProcessing, boolean forceProxy)
static void	pushMessageNow(PlatformMessage message, PlatformMessengerListener listener)	Sends the message almost immediately, skipping delayauthorization check
static void	queueMessage(PlatformMessage message, PlatformMessengerListener listener)
static void	queueMessage(PlatformMessage message, PlatformMessengerListener listener, boolean addToBottom)
static void	setAllowMulti(boolean allowMulti)

Methods inherited from class Object

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

Field Details

DEBUG_URL

private static final boolean DEBUG_URL

URL_PLATFORM_MESSAGE

private static final String URL_PLATFORM_MESSAGE

See Also:

• Constant Field Values

URL_POST_PLATFORM_DATA

private static final 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 String REPLY_EXCEPTION

REPLY_ACTION

public static String REPLY_ACTION

REPLY_RESULT

public static String REPLY_RESULT

mapQueues

static Map<String, Map<PlatformMessage, PlatformMessengerListener>> mapQueues

Key: id of queue; Value: Map of queued messages invalid input: '&' listeners

QUEUE_NOAZID

private static final String QUEUE_NOAZID

See Also:

• Constant Field Values

QUEUE_NORMAL

private static final String QUEUE_NORMAL

See Also:

• Constant Field Values

queue_mon

private static AEMonitor queue_mon

timerProcess

private static Timer timerProcess

mapTimerEvents

static Map<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 Map<String,Object> mapExtra

Constructor Details

PlatformMessenger

public PlatformMessenger()

Method Details

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(String string)

Parameters:

string -

debug

protected static void debug(String string,
 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(String queueID,
 Map mapQueue)

processQueueAsync

protected static void processQueueAsync(String sURL,
 String sData,
 Map mapProcessing,
 boolean forceProxy)
                                 throws Throwable

Parameters:

mapProcessing -

Throws:

Exception

Throwable

downloadURL

private static Object[] downloadURL(URL rpc_url,
 String postData,
 boolean forceProxy)
                             throws Throwable

Throws:

Throwable

downloadURLSupport

private static Object[] downloadURLSupport(Proxy proxy,
 String proxy_host,
 URL url,
 String postData)
                                    throws Throwable

Throws:

Throwable

setAllowMulti

public static void setAllowMulti(boolean allowMulti)

getAllowMulti

public static boolean getAllowMulti()

addExtraParam

public static void addExtraParam(String key,
 Object value)