protected class JMSBridgeModule.ConsumerDaemon extends Daemon
ConsumerDaemon
thread allows to call
MessageConsumer.receive()
for requesting a foreign JMS
message without blocking the JORAM server.Modifier and Type | Field and Description |
---|---|
private Object |
consumerLock
object for synchronization
|
(package private) boolean |
receiveRequest
true if new "receive" request
|
private int |
requests
Counter of pending "receive" requests.
|
Modifier | Constructor and Description |
---|---|
protected |
ConsumerDaemon()
Constructs a
ReceiverDaemon thread. |
Modifier and Type | Method and Description |
---|---|
void |
close()
Releases the daemon's resources.
|
private void |
process() |
protected void |
receive()
Notifies the daemon of a new "receive" request.
|
void |
run()
The daemon's loop.
|
void |
shutdown()
Shuts the daemon down.
|
void |
start()
Causes this daemon to begin execution.
|
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, stop, toString
private int requests
private Object consumerLock
boolean receiveRequest
protected void receive()
public void start()
Daemon
start
in class Daemon
Daemon.start()
public void run()
private void process() throws JMSException
JMSException
Copyright © 2021 ScalAgent D.T.. All rights reserved.