|
|
@ -141,7 +141,7 @@ public class ServiceSend extends LifecycleService {
|
|
|
|
message = db.message().getMessage(op.message);
|
|
|
|
message = db.message().getMessage(op.message);
|
|
|
|
if (message == null)
|
|
|
|
if (message == null)
|
|
|
|
throw new MessageRemovedException();
|
|
|
|
throw new MessageRemovedException();
|
|
|
|
send(message);
|
|
|
|
onSend(message);
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
|
|
case EntityOperation.ANSWERED:
|
|
|
|
case EntityOperation.ANSWERED:
|
|
|
@ -290,7 +290,7 @@ public class ServiceSend extends LifecycleService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
private void send(EntityMessage message) throws MessagingException, IOException {
|
|
|
|
private void onSend(EntityMessage message) throws MessagingException, IOException {
|
|
|
|
DB db = DB.getInstance(this);
|
|
|
|
DB db = DB.getInstance(this);
|
|
|
|
|
|
|
|
|
|
|
|
// Mark attempt
|
|
|
|
// Mark attempt
|
|
|
|