Uses rescheduling
This commit is contained in:
parent
a59a274bb6
commit
3512d4d4e9
@ -114,8 +114,8 @@ public class RandomTraderA extends AutoTraderBase implements AccountListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void setStatus(String format, Object... arguments) {
|
void setStatus(String format, Object... arguments) {
|
||||||
String s = String.format(format, arguments);
|
// String s = String.format(format, arguments);
|
||||||
System.out.printf("%s: %s\n", this.getName(), s);
|
// System.out.printf("%s: %s\n", this.getName(), s);
|
||||||
}
|
}
|
||||||
|
|
||||||
private Float[] to_float(JSONArray a) {
|
private Float[] to_float(JSONArray a) {
|
||||||
@ -191,20 +191,19 @@ public class RandomTraderA extends AutoTraderBase implements AccountListener {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void accountUpdated(Account a, Exchange.Order o) {
|
public void accountUpdated(Account a, Exchange.Order o) {
|
||||||
// System.out.printf("Order what %s %d\n", o.getOrderStatus().toString(), Thread.currentThread().getId());
|
//System.out.printf("Order updated %s %d\n", o.getOrderStatus().toString(), Thread.currentThread().getId());
|
||||||
if (o.getOrderStatus() == OrderStatus.CLOSED) {
|
if (o.getOrderStatus() == OrderStatus.CLOSED) {
|
||||||
|
|
||||||
// System.out.printf("Enteter canel timer %d\n", Thread.currentThread().getId());
|
// System.out.printf("Enteter canel timer %d\n", Thread.currentThread().getId());
|
||||||
// se.timer.cancelTimerTask(this);
|
|
||||||
//System.out.printf("back from canel timer %d\n", System.identityHashCode(this));
|
//System.out.printf("back from canel timer %d\n", System.identityHashCode(this));
|
||||||
//System.exit(0);
|
//System.exit(0);
|
||||||
|
// setStatus("Order closed, %s", o.getType().toString());
|
||||||
Long w = waitAfterOrder();
|
Long w = waitAfterOrder();
|
||||||
|
|
||||||
setStatus("Order closed, %s", o.getType().toString());
|
|
||||||
|
|
||||||
// System.out.printf("We have now to wait for %d\n", w);
|
// System.out.printf("We have now to wait for %d\n", w);
|
||||||
//timerTask = se.timer.startTimerTask(this, w);
|
// se.timer.cancelTimerTask(this);
|
||||||
// se.timer.XXXrescheduleTimerTask(timerTask, w);
|
// timerTask = se.timer.startTimerTask(this, w);
|
||||||
|
se.timer.rescheduleTimerTask(timerTask, w);
|
||||||
}
|
}
|
||||||
// System.out.printf("Updatetd Account\n", "");
|
// System.out.printf("Updatetd Account\n", "");
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user