public class MFAdmin extends MFClient
| Modifier and Type | Class and Description |
|---|---|
static class |
MFAdmin.RiskLimit
Admin interface: group limit, optionally for a specific feed and market.
|
static class |
MFAdmin.RiskMarketPosition
Admin interface:
Use this if interested in market position rather than RiskUsage's net open position.
|
static class |
MFAdmin.RiskUsage
Admin interface: user state.
|
MFClient.OrderArgs, MFClient.PingTime, MFClient.TimeStats| Modifier and Type | Field and Description |
|---|---|
protected MFAdmin.RiskLimit[] |
_riskLimits |
protected long |
_riskTimestamp |
protected MFAdmin.RiskUsage[] |
_riskUsages |
protected java.util.List<com.marketfactory.api.TradeLimitDataMessage> |
_tradeLimitDataQueue |
protected java.util.Map<java.lang.String,java.lang.String[]> |
_userGroupChains |
static int |
FEED_ALL |
static int |
FEED_NULL
Pair with marketID to reference individual currencies.
|
static int |
MARKET_ALL |
static long |
SETTL_DATE_CASH |
static long |
SETTL_DATE_SUM |
| Constructor and Description |
|---|
MFAdmin(java.lang.String _username,
java.lang.String _password,
java.lang.String _hostname1,
int _port1)
Create a new admin object.
|
MFAdmin(java.lang.String _username,
java.lang.String _password,
java.lang.String _hostname1,
int _port1,
java.lang.String _hostname2,
int _port2)
Create a new admin object (with failover).
|
| Modifier and Type | Method and Description |
|---|---|
protected static java.lang.String |
addUpdateType(java.lang.String id,
boolean doReplace) |
APIResult |
allowClientsToConnect()
Admin interface: Call this method to allow monitored API clients to connect.
|
protected static java.lang.String |
delUpdateType(java.lang.String id) |
protected static java.lang.String |
getLimitID(java.lang.String mfUser,
java.lang.String group,
int feedID,
int marketID) |
MFAdmin.RiskLimit[] |
getRiskLimits()
Admin interface: limits registered by server process.
|
MFAdmin.RiskMarketPosition[] |
getRiskMarketPositions()
Admin interface:
Returns array of derived RiskMarketPositions rather than RiskUsage.
|
long |
getRiskTimestamp()
Admin interface: timestamp of last constraint update from server process.
|
MFAdmin.RiskUsage[] |
getRiskUsage()
Admin interface: full risk usage view held by server process.
|
java.util.Map<java.lang.String,java.lang.String[]> |
getUserGroupChains()
Admin interface: linear list of groups to which each user belongs.
|
void |
handle(com.marketfactory.api.TradeLimitDataMessage msg) |
APIResult |
lockUser(java.lang.String clRequestID,
java.lang.String username,
boolean locked)
Admin interface: Lock / unlock user accounts.
|
static MFAdmin |
open(java.lang.String user,
java.lang.String pass,
java.lang.String host,
int port)
A convenience method which creates a new client object, attempts to
connect to Whisperer, and cleans up and throws an exception if we could
not connect.
|
static MFAdmin |
open(java.lang.String user,
java.lang.String pass,
java.lang.String _hostname1,
int _port1,
java.lang.String _hostname2,
int _port2)
A convenience method which creates a new client object, attempts to
connect to Whisperer, and cleans up and throws an exception if we could
not connect.
|
APIResult |
run(MFAdminHandler handler)
Run a loop that will continuously dispatch incoming messages to a
_handler implementation.
|
APIResult |
run(MFHandler _handler)
Run a loop that will continuously dispatch incoming messages to a
_handler implementation.
|
APIResult |
setRisk(java.lang.String clRequestID,
boolean doReplace,
MFAdmin.RiskUsage... usages) |
APIResult |
setRisk(java.lang.String clRequestID,
MFAdmin.RiskLimit... limits)
Admin interface: publish incremental set of limits.
|
APIResult |
setRisk(java.lang.String clRequestID,
MFAdmin.RiskLimit[] limits,
MFAdmin.RiskUsage[] usages,
boolean isSnapshot)
Admin interface: publish incremental/snapshot set of limits and usage.
|
APIResult |
setRisk(java.lang.String clRequestID,
MFAdmin.RiskLimit[] limits,
MFAdmin.RiskUsage[] usages,
boolean isSnapshot,
boolean doReplace) |
APIResult |
setRisk(java.lang.String clRequestID,
MFAdmin.RiskUsage... usages)
Admin interface: publish incremental set of risk usage.
|
cancelAll, cancelAll, cancelOrder, cancelOrder, cancelOrder, close, connect, enableDebugMetrics, getFeedByID, getFeedByName, getFeeds, getHostname, getLastPingTimes, getMarketByID, getMarketByName, getPort, getSequenceID, getSignature, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, isConnected, isRunning, join, log, log, modifyOrder, processEvents, registerMarketComb, replay, requestSnapshot, send, setDebug, setStickySubscriptions, setStickySubscriptions, setUseHeartbeat, stop, submitOrder, submitOrder, submitOrder, submitOrder, subscribeAllMD, subscribeMD, subscribeMD, subscribeOF, subscribeOF, test, unregisterMarketComb, unsubscribeAll, unsubscribeMD, unsubscribeMD, unsubscribeOF, unsubscribeOFprotected java.util.Map<java.lang.String,java.lang.String[]> _userGroupChains
protected MFAdmin.RiskLimit[] _riskLimits
protected MFAdmin.RiskUsage[] _riskUsages
protected long _riskTimestamp
protected java.util.List<com.marketfactory.api.TradeLimitDataMessage> _tradeLimitDataQueue
public static final int FEED_NULL
public static final int FEED_ALL
public static final int MARKET_ALL
public static final long SETTL_DATE_SUM
public static final long SETTL_DATE_CASH
public MFAdmin(java.lang.String _username,
java.lang.String _password,
java.lang.String _hostname1,
int _port1)
public MFAdmin(java.lang.String _username,
java.lang.String _password,
java.lang.String _hostname1,
int _port1,
java.lang.String _hostname2,
int _port2)
public APIResult run(MFHandler _handler)
MFClientpublic APIResult run(MFAdminHandler handler)
public static MFAdmin open(java.lang.String user, java.lang.String pass, java.lang.String host, int port) throws java.io.IOException
java.io.IOExceptionpublic static MFAdmin open(java.lang.String user, java.lang.String pass, java.lang.String _hostname1, int _port1, java.lang.String _hostname2, int _port2) throws java.io.IOException
java.io.IOExceptionprotected static java.lang.String getLimitID(java.lang.String mfUser,
java.lang.String group,
int feedID,
int marketID)
protected static java.lang.String addUpdateType(java.lang.String id,
boolean doReplace)
protected static java.lang.String delUpdateType(java.lang.String id)
public void handle(com.marketfactory.api.TradeLimitDataMessage msg)
public APIResult allowClientsToConnect()
public APIResult lockUser(java.lang.String clRequestID, java.lang.String username, boolean locked)
public APIResult setRisk(java.lang.String clRequestID, MFAdmin.RiskLimit[] limits, MFAdmin.RiskUsage[] usages, boolean isSnapshot)
clRequestID - limits - usages - isSnapshot - public APIResult setRisk(java.lang.String clRequestID, MFAdmin.RiskLimit[] limits, MFAdmin.RiskUsage[] usages, boolean isSnapshot, boolean doReplace)
public APIResult setRisk(java.lang.String clRequestID, MFAdmin.RiskLimit... limits)
public APIResult setRisk(java.lang.String clRequestID, MFAdmin.RiskUsage... usages)
public APIResult setRisk(java.lang.String clRequestID, boolean doReplace, MFAdmin.RiskUsage... usages)
public MFAdmin.RiskLimit[] getRiskLimits()
public MFAdmin.RiskUsage[] getRiskUsage()
public MFAdmin.RiskMarketPosition[] getRiskMarketPositions()
public long getRiskTimestamp()
public java.util.Map<java.lang.String,java.lang.String[]> getUserGroupChains()