ziver/zutil
1
0
Fork 0
Code Issues Pull requests Activity Actions

Fixed duplicate case file names

Browse source
This commit is contained in:
Ziver Koc 2017-08-01 23:16:37 +02:00
parent 8b7f8a5bc4
commit f1352cb58a
2 changed files with 0 additions and 86 deletions
Download patch file Download diff file Expand all files Collapse all files

79
src/zutil/net/mqtt/MQTTBroker.java
View file

@ -1,79 +0,0 @@
package zutil.net.mqtt;
import zutil.log.LogUtil;
import zutil.net.mqtt.packet.MqttPacket;
import zutil.net.mqtt.packet.MqttPacketConnect;
import zutil.net.mqtt.packet.MqttPacketConnectAck;
import zutil.net.threaded.ThreadedTCPNetworkServer;
import zutil.net.threaded.ThreadedTCPNetworkServerThread;
import zutil.parser.binary.BinaryStructInputStream;
import zutil.parser.binary.BinaryStructOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
* TODO:
*/
public class MqttBroker extends ThreadedTCPNetworkServer{
private static final Logger logger = LogUtil.getLogger();
public static final int MQTT_PORT = 1883;
public static final int MQTT_PORT_TLS = 8883;
public MqttBroker(){
super(MQTT_PORT);
}
@Override
protected ThreadedTCPNetworkServerThread getThreadInstance(Socket s) throws IOException {
return new MQTTConnectionThread(s);
}
private static class MQTTConnectionThread implements ThreadedTCPNetworkServerThread {
private Socket socket;
private BinaryStructInputStream in;
private BinaryStructOutputStream out;
private MQTTConnectionThread(Socket s) throws IOException {
socket = s;
in = new BinaryStructInputStream(socket.getInputStream());
out = new BinaryStructOutputStream(socket.getOutputStream());
}
@Override
public void run() {
try {
MqttPacket packet = MqttPacket.read(in);
// Unexpected packet?
if ( ! (packet.header instanceof MqttPacketConnect))
throw new IOException("Expected MqttPacketConnect but received "+packet.header.getClass());
MqttPacketConnect conn = (MqttPacketConnect) packet.header;
// Incorrect protocol version?
if (conn.protocolLevel != 0x04){
MqttPacketConnectAck connack = new MqttPacketConnectAck();
connack.returnCode = MqttPacketConnectAck.RETCODE_PROT_VER_ERROR;
MqttPacket.write(out, connack);
return;
}
} catch (IOException e) {
logger.log(Level.SEVERE, null, e);
} finally {
try {
socket.close();
} catch (IOException e) {
logger.log(Level.SEVERE, null, e);
}
}
}
}
}

7
src/zutil/net/mqtt/MQTTClient.java
View file

@ -1,7 +0,0 @@
package zutil.net.mqtt;
/**
* TODO:
*/
public class MqttClient {
}