public class Heating
extends java.lang.Object
import static com.github.niqdev.openwebnet.OpenWebNet.defaultGateway;
// reads temperature
OpenWebNet
.newClient(defaultGateway("IP_ADDRESS"))
.send(Heating.requestTemperature("WHERE"))
.map(Heating.handleTemperature(value -> System.out.println(value), () -> System.out.println("error")))
.subscribe(System.out::println);
Modifier and Type | Class and Description |
---|---|
static class |
Heating.TemperatureScale
Common temperature scale.
|
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
FORMAT_BUS |
protected static java.lang.String |
FORMAT_DIMENSION |
protected static java.lang.String |
FORMAT_PREFIX_DIMENSION |
protected static java.lang.String |
FORMAT_PREFIX_DIMENSION_WHO |
protected static java.lang.String |
FORMAT_PREFIX_REQUEST_WHO |
protected static java.lang.String |
FORMAT_PREFIX_RESPONSE |
protected static java.lang.String |
FORMAT_PREFIX_STATUS_WHO |
protected static java.lang.String |
FORMAT_REQUEST |
protected static java.lang.String |
FORMAT_STATUS |
static java.lang.String |
NO_BUS |
static java.lang.String |
WHERE_GENERAL_VALUE |
protected static java.lang.String |
WHERE_GROUP_PREFIX |
protected static int |
WHERE_MAX_VALUE |
protected static int |
WHERE_MIN_VALUE |
ACK, FRAME_END, FRAME_START, NACK
Modifier and Type | Method and Description |
---|---|
protected static java.lang.String |
checkBus(java.lang.String bus) |
protected static int |
checkIsInteger(java.lang.String value) |
protected static void |
checkRange(java.lang.Integer from,
java.lang.Integer to,
java.lang.Integer value) |
java.lang.String |
getValue()
Raw message value.
|
protected static rx.functions.Func1<OpenSession,OpenSession> |
handleResponse(rx.functions.Action0 onSuccess,
rx.functions.Action0 onFail,
int who) |
static rx.functions.Func1<OpenSession,OpenSession> |
handleTemperature(rx.functions.Action1<java.lang.Double> onSuccess,
rx.functions.Action0 onError)
Handle response from
requestTemperature(String, TemperatureScale) . |
protected static boolean |
isInRange(java.lang.Integer from,
java.lang.Integer to,
java.lang.Integer value) |
protected static java.lang.Boolean |
isValidBus(java.lang.String bus) |
protected static void |
isValidPrefixType(OpenMessage request,
java.lang.String format,
int who) |
static Heating |
requestTemperature(java.lang.String where)
OpenWebNet message request to read temperature in
Heating.TemperatureScale.CELSIUS and value *4*WHERE*0##. |
static Heating |
requestTemperature(java.lang.String where,
Heating.TemperatureScale scale)
OpenWebNet message request to read temperature with a specific
Heating.TemperatureScale and value *4*WHERE*0##. |
protected static final java.lang.String FORMAT_PREFIX_REQUEST_WHO
protected static final java.lang.String FORMAT_PREFIX_DIMENSION_WHO
protected static final java.lang.String FORMAT_PREFIX_STATUS_WHO
protected static final java.lang.String FORMAT_REQUEST
protected static final java.lang.String FORMAT_DIMENSION
protected static final java.lang.String FORMAT_STATUS
protected static final java.lang.String FORMAT_PREFIX_RESPONSE
protected static final java.lang.String FORMAT_PREFIX_DIMENSION
protected static final java.lang.String FORMAT_BUS
protected static final int WHERE_MIN_VALUE
protected static final int WHERE_MAX_VALUE
protected static final java.lang.String WHERE_GROUP_PREFIX
public static final java.lang.String WHERE_GENERAL_VALUE
public static final java.lang.String NO_BUS
public static Heating requestTemperature(java.lang.String where, Heating.TemperatureScale scale)
Heating.TemperatureScale
and value *4*WHERE*0##.where
- Value between 0 and 899scale
- Temperature scalepublic static Heating requestTemperature(java.lang.String where)
Heating.TemperatureScale.CELSIUS
and value *4*WHERE*0##.where
- Value between 0 and 899public static rx.functions.Func1<OpenSession,OpenSession> handleTemperature(rx.functions.Action1<java.lang.Double> onSuccess, rx.functions.Action0 onError)
requestTemperature(String, TemperatureScale)
.onSuccess
- invoked if the temperature has been read correctlyonError
- invoked otherwiseObservable<OpenSession>
public java.lang.String getValue()
OpenMessage
getValue
in interface OpenMessage
protected static void checkRange(java.lang.Integer from, java.lang.Integer to, java.lang.Integer value)
protected static boolean isInRange(java.lang.Integer from, java.lang.Integer to, java.lang.Integer value)
protected static int checkIsInteger(java.lang.String value)
protected static void isValidPrefixType(OpenMessage request, java.lang.String format, int who)
protected static rx.functions.Func1<OpenSession,OpenSession> handleResponse(rx.functions.Action0 onSuccess, rx.functions.Action0 onFail, int who)
protected static java.lang.String checkBus(java.lang.String bus)
protected static java.lang.Boolean isValidBus(java.lang.String bus)