Adding user to their own contacts, reusing one database transaction
Fixes #15
This commit is contained in:
@ -33,6 +33,7 @@ public class ObjectMessageProcessor implements IMessageProcessor {
|
||||
*/
|
||||
public ObjectMessageProcessor(Set<ObjectProcessor<?>> processors) { this.processors = processors; }
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Override
|
||||
public void process(Message message, WriteProxy writeProxy) {
|
||||
try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(message.sharedArray, message.offset + 4, message.length - 4))) {
|
||||
|
Reference in New Issue
Block a user