diff --git a/src/main/java/com/github/manevolent/ts3j/protocol/packet/handler/client/LocalClientHandlerFull.java b/src/main/java/com/github/manevolent/ts3j/protocol/packet/handler/client/LocalClientHandlerFull.java index 1833f0d..d47859f 100644 --- a/src/main/java/com/github/manevolent/ts3j/protocol/packet/handler/client/LocalClientHandlerFull.java +++ b/src/main/java/com/github/manevolent/ts3j/protocol/packet/handler/client/LocalClientHandlerFull.java @@ -55,12 +55,12 @@ public abstract class LocalClientHandlerFull extends LocalClientHandler { break; case VOICE: - Consumer handler = getClient().getVoiceHandler(); - if (handler != null) handler.accept((PacketBody0Voice) packet.getBody()); + Consumer handler = getClient().getVoiceHandler(); + if (handler != null) handler.accept(packet); break; case VOICE_WHISPER: - Consumer whisperConsumer = getClient().getWhisperHandler(); - if (whisperConsumer != null) whisperConsumer.accept((PacketBody1VoiceWhisper) packet.getBody()); + Consumer whisperConsumer = getClient().getWhisperHandler(); + if (whisperConsumer != null) whisperConsumer.accept(packet); break; } } diff --git a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/AbstractTeamspeakClientSocket.java b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/AbstractTeamspeakClientSocket.java index 00199a7..133b9f0 100644 --- a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/AbstractTeamspeakClientSocket.java +++ b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/AbstractTeamspeakClientSocket.java @@ -70,8 +70,8 @@ public abstract class AbstractTeamspeakClientSocket private CommandProcessor commandProcessor; - private Consumer voiceHandler; - private Consumer whisperHandler; + private Consumer voiceHandler; + private Consumer whisperHandler; private Consumer exceptionHandler = Throwable::printStackTrace; @@ -897,19 +897,19 @@ public abstract class AbstractTeamspeakClientSocket this.exceptionHandler = exceptionHandler; } - public Consumer getVoiceHandler() { + public Consumer getVoiceHandler() { return voiceHandler; } - public void setVoiceHandler(Consumer voiceHandler) { + public void setVoiceHandler(Consumer voiceHandler) { this.voiceHandler = voiceHandler; } - public Consumer getWhisperHandler() { + public Consumer getWhisperHandler() { return whisperHandler; } - public void setWhisperHandler(Consumer whisperHandler) { + public void setWhisperHandler(Consumer whisperHandler) { this.whisperHandler = whisperHandler; } diff --git a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java index 2a2f23d..c3a1482 100644 --- a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java +++ b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java @@ -605,7 +605,7 @@ public class LocalTeamspeakClientSocket private void handleComplete(SingleCommand command) throws IOException, TimeoutException { try { synchronized (commandSendLock) { - awaitingCommands.remove(returnCode); + awaitingCommands.remove(getReturnCode()); acceptingReturnCode = calculateAcceptingReturnCode(); } @@ -690,12 +690,11 @@ public class LocalTeamspeakClientSocket switch (getState()) { case RETRIEVING_DATA: case CONNECTED: - Command banCommand = new SingleCommand("clientupdate", ProtocolRole.CLIENT); - - banCommand.add(new CommandSingleParameter("client_nickname", nickname)); + Command command = new SingleCommand("clientupdate", ProtocolRole.CLIENT); + command.add(new CommandSingleParameter("client_nickname", nickname)); try { - executeCommand(banCommand).complete(); + executeCommand(command).complete(); } catch (Exception e) { throw new RuntimeException(e); } diff --git a/src/test/java/com/github/manevolent/ts3j/ServerConnectionTest.java b/src/test/java/com/github/manevolent/ts3j/ServerConnectionTest.java index 907d5cf..752950c 100644 --- a/src/test/java/com/github/manevolent/ts3j/ServerConnectionTest.java +++ b/src/test/java/com/github/manevolent/ts3j/ServerConnectionTest.java @@ -24,7 +24,7 @@ public class ServerConnectionTest { Ts3Debugging.setEnabled(true); - LocalIdentity identity = LocalIdentity.generateNew(9); + LocalIdentity identity = LocalIdentity.generateNew(10); client.setIdentity(identity); client.setNickname("ts3j issue 2");