@Override
public void run() {
- logger.debug("Receiver thread started");
+ logger.debug("Starting receiver thread");
while (!interrupted()) {
try {
Optional<String> message = readLineBlocking();
@Override
public void run() {
- logger.debug("Sender thread started");
+ logger.debug("Starting sender thread");
while (!interrupted()) {
try {
DigiplexRequest request = sendQueue.take();
@Override
public void handleCommand(ChannelUID channelUID, Command command) {
if (command instanceof RefreshType) {
- logger.debug("Intellflo received refresh command");
+ logger.debug("IntelliFlo received refresh command");
updateChannel(channelUID.getId(), null);
}
}
private void sendMessage(String str) throws IOException {
if (isConnected()) {
- logger.debug("send message fo {}: {}", uri.toString(), str);
+ logger.debug("send message for {}: {}", uri.toString(), str);
session.getRemote().sendString(str);
} else {
String stack = "";
encodeCipher.init(1, secretKeySpec, ivParameterSpec);
decodeCipher.init(2, secretKeySpec, ivParameterSpec);
} catch (Exception e) {
- logger.warn("initChiper failed: {}", e.getMessage());
+ logger.warn("initCipher failed: {}", e.getMessage());
encodeCipher = null;
decodeCipher = null;
}