ericek111/ts3j
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Pull up socket role

Browse Source
This commit is contained in:
Manevolent
2018-08-23 08:48:58 -04:00
parent 1ec7796a02
commit 09c21b171e
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/github/manevolent/ts3j/protocol/socket/client/AbstractTeamspeakClientSocket.java
+2 -2
View File
@@ -107,8 +107,8 @@ public abstract class AbstractTeamspeakClientSocket
private boolean reading = false;
protected AbstractTeamspeakClientSocket() {
super(SocketRole.CLIENT);
protected AbstractTeamspeakClientSocket(SocketRole role) {
super(role);
// Initialize reassembly queue
for (PacketBodyType bodyType : PacketBodyType.values())
src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java
+2 -1
View File
@@ -15,6 +15,7 @@ import com.github.manevolent.ts3j.identity.Uid;
import com.github.manevolent.ts3j.protocol.NetworkPacket;
import com.github.manevolent.ts3j.protocol.PacketKind;
import com.github.manevolent.ts3j.protocol.ProtocolRole;
import com.github.manevolent.ts3j.protocol.SocketRole;
import com.github.manevolent.ts3j.protocol.client.ClientConnectionState;
import com.github.manevolent.ts3j.protocol.header.PacketHeader;
import com.github.manevolent.ts3j.protocol.packet.PacketBody0Voice;
@@ -60,7 +61,7 @@ public class LocalTeamspeakClientSocket
private Map<Integer, ClientCommandResponse> awaitingCommands = new ConcurrentHashMap<>();
public LocalTeamspeakClientSocket() {
super();
super(SocketRole.CLIENT);
namedProcessors.put("initserver", new InitServerHandler());