Thread sleep 30 sekunden - wenn keine Antwort bis dahin neu senden

[whasabi]

Hallo,

ich habe einen Thread A der über eine MessageQueue eine Nachricht an ThreadB sendet
ich will nun, dass mir dieser Thread B innerhalb der nächsten 30 Sekunden eine Antwort sendet - sonst muss der Thread A nochmal seine Nachricht senden
(wieso Thread? Weil er generell eigentlich nach 15 Minuten mir immer wieder eine Nachricht schicken soll - deswegen brauch ich auch noch irgendwo ein weiteres Thread.sleep(15min))

Ich habe nun in Thread a eine run() Methode wo ich zB MessageProducer und Message Consumer instanziere, und die Nachricht sende und den Messageconsumer.setMessageListener(this); setze

Danach mache ich Thread.sleep(15000);

In der Methode onMessage holt er sich die TextMessage heraus mit der ID

Wo und wie kann ich einbauen, dass er nur nach den 30 sekunden einmal schaut ob er eine Nachricht bekommen hat und wenn nicht nochmal sendet?
DANKE 🙂

 

[dayaftereh]

Benutze doch ein ScheduledExecutorService...

 

[Joose]

Du könntest auch einfach eine BlockingQueue dazu verwenden. Dieser kannst du im "poll" ein Timeout mitgeben wie lange maximal auf etwas gewartet werden soll.
Ansonsten bekommt man einfach "null" zurück.
https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html