org.miloss.fgsms.agentcore

Class DataPusher

java.lang.Object

org.miloss.fgsms.agentcore.DataPusher

All Implemented Interfaces:

Runnable

public class DataPusher
extends Object
implements Runnable

fgsms's Java Data Pusher Asynchronously handles the caching, loading, storing and sending of all record data for transactional web services.

Since:

3.0

Author:

AO

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataPusher() used only for the Persistent storage agent
	DataPusher(HashMap cache, ConcurrentLinkedQueue queue)

Method Summary

Methods

Modifier and Type	Method and Description
protected static org.miloss.fgsms.services.interfaces.datacollector.AddMoreData	CheckPersistStore() checks the local file system for files that were not able to be sent if present,
protected static void	EnsureFolderExists(String folder)
protected static void	Init() loads all configuration data, setups up the remote service proxies for PCS and DCS
protected static String	IpWrapAndCacher(String URL, boolean isclient) caches IP to DNS mappings to speed up performance this may block if an ip address is not resolvable or there is some kind of DNS related problem
static org.miloss.fgsms.services.interfaces.policyconfiguration.ServicePolicyResponseMsg	LoadDefaultPolicy(String url) Loads the default policy from disk defaultpolicy.xml
static List<org.miloss.fgsms.plugins.agents.IEndpointDiscovery>	LoadEndpointProviders(ConfigLoader cl)
static PolicyHelper	LoadPolicy(String url, boolean isclient) Entry point for loading a policy, if one cannot be fetched from the PCS, the default policy is returned
protected static String	ReadAllText(InputStream in)
void	run() Run's until the outbound queue is empty, sends at most 40 message or 1 MB of data (if message logging is on) at a time.
protected static void	StorePersist(org.miloss.fgsms.services.interfaces.datacollector.AddMoreData req) serializes the request to a string, encrypts it, then stores it to disk

Methods inherited from class java.lang.Object

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

Constructor Detail

DataPusher

public DataPusher(HashMap cache,
          ConcurrentLinkedQueue queue)

DataPusher

protected DataPusher()

used only for the Persistent storage agent

Method Detail

Init

protected static void Init()

loads all configuration data, setups up the remote service proxies for PCS and DCS

IpWrapAndCacher

protected static String IpWrapAndCacher(String URL,
                     boolean isclient)

caches IP to DNS mappings to speed up performance this may block if an ip address is not resolvable or there is some kind of DNS related problem

Parameters:

URL -

isclient -

Returns:

LoadPolicy

public static PolicyHelper LoadPolicy(String url,
                      boolean isclient)

Entry point for loading a policy, if one cannot be fetched from the PCS, the default policy is returned

Parameters:

url -

Returns:

LoadDefaultPolicy

public static org.miloss.fgsms.services.interfaces.policyconfiguration.ServicePolicyResponseMsg LoadDefaultPolicy(String url)

Loads the default policy from disk defaultpolicy.xml

Parameters:

url -

Returns:

run

public void run()

Run's until the outbound queue is empty, sends at most 40 message or 1 MB of data (if message logging is on) at a time.

Specified by:

run in interface Runnable

CheckPersistStore

protected static org.miloss.fgsms.services.interfaces.datacollector.AddMoreData CheckPersistStore()

checks the local file system for files that were not able to be sent if present,

EnsureFolderExists

protected static void EnsureFolderExists(String folder)

StorePersist

protected static void StorePersist(org.miloss.fgsms.services.interfaces.datacollector.AddMoreData req)

serializes the request to a string, encrypts it, then stores it to disk

ReadAllText

protected static String ReadAllText(InputStream in)

LoadEndpointProviders

public static List<org.miloss.fgsms.plugins.agents.IEndpointDiscovery> LoadEndpointProviders(ConfigLoader cl)