zdm/envoy
zdm/envoy
Archived
3
Fork 0
Code Issues 22 Pull Requests Releases 1 Wiki Activity

Implemented Changes as requested by @CyB3RC0nN0R

Browse Source
This commit is contained in:
delvh 2020-01-30 18:40:54 +01:00
parent 99ff79b022
commit 44dd79ba6d
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/envoy/server/processors/MessageStatusChangeProcessor.java
View File

@ -20,13 +20,6 @@ import envoy.server.net.ObjectWriteProxy;
*/ */
public class MessageStatusChangeProcessor implements ObjectProcessor<MessageStatusChangeEvent> { public class MessageStatusChangeProcessor implements ObjectProcessor<MessageStatusChangeEvent> {
/**
* Creates an instance of @link{MessageStatusChangeProcessor}.
*
* @since Envoy Server Standalone v0.1-alpha
*/
public MessageStatusChangeProcessor() {}
@Override @Override
public Class<MessageStatusChangeEvent> getInputClass() { return MessageStatusChangeEvent.class; } public Class<MessageStatusChangeEvent> getInputClass() { return MessageStatusChangeEvent.class; }
@ -34,7 +27,7 @@ public class MessageStatusChangeProcessor implements ObjectProcessor<MessageStat
public void process(MessageStatusChangeEvent input, long socketId, ObjectWriteProxy writeProxy) throws IOException { public void process(MessageStatusChangeEvent input, long socketId, ObjectWriteProxy writeProxy) throws IOException {
try { try {
// any other status than read is not supposed to be sent to the server // any other status than read is not supposed to be sent to the server
if (!(input.get() == MessageStatus.READ)) throw new EnvoyException("Message" + input.getId() + "has an invalid status"); if (input.get() != MessageStatus.READ) throw new EnvoyException("Message" + input.getId() + "has an invalid status");
} catch (EnvoyException e) { } catch (EnvoyException e) {
e.printStackTrace(); e.printStackTrace();
return; return;