}
}
public void queuePendingMessagesOnConnectionRestartAsync(FCPConnectionOutputHandler outputHandler, ClientContext context) {
if(persistence == Persistence.FOREVER) {
PersistentListJob job = new PersistentListJob(this, outputHandler, context) {
@Override
void complete(ClientContext context) {
// Do nothing.
}
};
job.run(context);
} else {
TransientListJob job = new TransientListJob(this, outputHandler, context) {
@Override
void complete(ClientContext context) {
// Do nothing.
}
};
job.run(context);
}
}