Package jmri.server.json.throttle

Class JsonThrottle

java.lang.Object

jmri.server.json.throttle.JsonThrottle

All Implemented Interfaces:

PropertyChangeListener, EventListener, ThrottleListener

public class JsonThrottle
extends Object
implements ThrottleListener, PropertyChangeListener

Nested Class Summary

Nested classes/interfaces inherited from interface jmri.ThrottleListener

ThrottleListener.DecisionType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLIENTS	Used to notify clients of the number of clients controlling the same throttle.
static final String	ESTOP	"eStop"
static final String	IDLE	"idle"
static final String	RELEASE	"release"
static final String	SPEED_STEPS	"speedSteps"
static final String	THROTTLE	Token for type for throttle status messages.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JsonThrottle(DccLocoAddress address, JsonThrottleSocketService server)

Method Summary

Modifier and Type	Method	Description
void	close(JsonThrottleSocketService server, boolean notifyClient)
(package private) Throttle	getThrottle()	Get the Throttle this JsonThrottle is a proxy for.
static JsonThrottle	getThrottle(String throttleId, com.fasterxml.jackson.databind.JsonNode data, JsonThrottleSocketService server, int id)	Creates a new JsonThrottle or returns an existing one if the request is for an existing throttle.
void	notifyDecisionRequired(LocoAddress address, ThrottleListener.DecisionType question)	No steal or share decisions made locally
void	notifyFailedThrottleRequest(LocoAddress address, String reason)	Get notification that an attempt to request a throttle has failed.
void	notifyThrottleFound(DccThrottle throttle)	Get notification that a throttle has been found as requested.
void	onMessage(Locale locale, com.fasterxml.jackson.databind.JsonNode data, JsonThrottleSocketService server)
void	propertyChange(PropertyChangeEvent evt)
void	release(JsonThrottleSocketService server, boolean notifyClient)
void	sendMessage(com.fasterxml.jackson.databind.node.ObjectNode data)
void	sendMessage(com.fasterxml.jackson.databind.node.ObjectNode data, JsonThrottleSocketService server)
protected void	sendStatus(JsonThrottleSocketService server)

Methods inherited from class java.lang.Object

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

Field Details

THROTTLE

public static final String THROTTLE

Token for type for throttle status messages.

"throttle"

See Also:

• Constant Field Values

RELEASE

public static final String RELEASE

"release"

See Also:

• Constant Field Values

ESTOP

public static final String ESTOP

"eStop"

See Also:

• Constant Field Values

IDLE

public static final String IDLE

"idle"

See Also:

• Constant Field Values

SPEED_STEPS

public static final String SPEED_STEPS

"speedSteps"

See Also:

• Constant Field Values

CLIENTS

public static final String CLIENTS

Used to notify clients of the number of clients controlling the same throttle.

"clients"

See Also:

• Constant Field Values

Constructor Details

JsonThrottle

protected JsonThrottle(DccLocoAddress address,
 JsonThrottleSocketService server)

Method Details

getThrottle

public static JsonThrottle getThrottle(String throttleId,
 com.fasterxml.jackson.databind.JsonNode data,
 JsonThrottleSocketService server,
 int id)
                                throws JsonException

Creates a new JsonThrottle or returns an existing one if the request is for an existing throttle.

data can contain either a string JSON.ID node containing the ID of a RosterEntry or an integer JSON.ADDRESS node. If data contains an ADDRESS, the ID node is ignored. The ADDRESS may be accompanied by a boolean JSON.IS_LONG_ADDRESS node specifying the type of address, if IS_LONG_ADDRESS is not specified, the inverse of ThrottleManager.canBeShortAddress(int) is used as the "best guess" of the address length.

Parameters:

throttleId - The client's identity token for this throttle

data - JSON object containing either an ADDRESS or an ID

server - The server requesting this throttle on behalf of a client

id - message id set by client

Returns:

The throttle

Throws:

JsonException - if unable to get the requested Throttle

close

public void close(JsonThrottleSocketService server,
 boolean notifyClient)

release

public void release(JsonThrottleSocketService server,
 boolean notifyClient)

onMessage

public void onMessage(Locale locale,
 com.fasterxml.jackson.databind.JsonNode data,
 JsonThrottleSocketService server)

sendMessage

public void sendMessage(com.fasterxml.jackson.databind.node.ObjectNode data)

sendMessage

public void sendMessage(com.fasterxml.jackson.databind.node.ObjectNode data,
 JsonThrottleSocketService server)

propertyChange

public void propertyChange(PropertyChangeEvent evt)

Specified by:

propertyChange in interface PropertyChangeListener

notifyThrottleFound

public void notifyThrottleFound(DccThrottle throttle)

Description copied from interface: ThrottleListener

Get notification that a throttle has been found as requested.

Specified by:

notifyThrottleFound in interface ThrottleListener

Parameters:

throttle - the throttle with the requested address

notifyFailedThrottleRequest

public void notifyFailedThrottleRequest(LocoAddress address,
 String reason)

Description copied from interface: ThrottleListener

Get notification that an attempt to request a throttle has failed.

Specified by:

notifyFailedThrottleRequest in interface ThrottleListener

Parameters:

address - address of the failed request

reason - failure cause

notifyDecisionRequired

public void notifyDecisionRequired(LocoAddress address,
 ThrottleListener.DecisionType question)

No steal or share decisions made locally

Get notification that a throttle request is in use by another device, and a "steal", "share", or "steal/share" decision may be required.

Specified by:

notifyDecisionRequired in interface ThrottleListener

Parameters:

address - The LocoAddress that needs the decision.

question - The question being asked, steal / cancel, share / cancel, steal / share / cancel

sendStatus

protected void sendStatus(JsonThrottleSocketService server)

getThrottle

Throttle getThrottle()

Get the Throttle this JsonThrottle is a proxy for.

Returns:

the throttle or null if no throttle is set