public class RestAcquisitionAsync extends Object implements AcquisitionDaemon
Modifier and Type | Class and Description |
---|---|
private class |
RestAcquisitionAsync.CheckTask
Task checking the acquisition mechanism.
|
private class |
RestAcquisitionAsync.XDaemon
Daemon for acquisition mechanism.
|
Modifier and Type | Field and Description |
---|---|
private long |
checkPeriod |
private TimerTask |
checkTask |
(package private) Client |
client |
private String |
clientId |
private int |
connectTimeout |
private String |
consName |
private RestAcquisitionAsync.XDaemon |
daemon |
private String |
destName |
private String |
hostName |
private String |
idleTimeout |
private long |
lastActivity |
private long |
lastMessage |
private static org.objectweb.util.monolog.api.Logger |
logger |
private boolean |
mediaTypeJson |
private int |
nbCnx |
private String |
password |
private boolean |
persistent |
private int |
port |
private Properties |
properties |
private int |
readTimeout |
private long |
round |
private String |
timeout |
private ReliableTransmitter |
transmitter |
private URI |
uriAcknowledgeMsg |
private URI |
uriCloseConsumer |
private URI |
uriReceiveNextMsg |
private boolean |
useOldAPI |
private String |
userName |
Constructor and Description |
---|
RestAcquisitionAsync() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
acknowledgeMessage() |
private void |
closeConsumer() |
private void |
createConsumer()
Gets destination and initializes the Rest/JMS consumer.
|
private Message |
createJSonMessage(HashMap<String,Object> map) |
private Message |
createTextMessage(String text) |
private Map<String,Object> |
getMapMessage(Map<String,Object> jsonMap) |
private Object |
getPropertyValue(String type,
String value) |
private void |
initFromProperties()
Initializes fields from properties.
|
boolean |
isConnected() |
private Message |
recvNextMessage() |
void |
restart() |
private void |
setJMSMessageHeader(Message msg,
Map header) |
private void |
setJMSProperties(Message msg,
Map props) |
void |
start(Properties properties,
ReliableTransmitter transmitter)
Tells the daemon to start with the given properties.
|
void |
stop()
Tells the daemon to stop.
|
private static final org.objectweb.util.monolog.api.Logger logger
private Properties properties
private ReliableTransmitter transmitter
private String hostName
private int port
private boolean useOldAPI
private final int connectTimeout
private final int readTimeout
private String userName
private String password
private String destName
private String consName
private String clientId
private String idleTimeout
private String timeout
private boolean mediaTypeJson
private boolean persistent
private long checkPeriod
private TimerTask checkTask
private RestAcquisitionAsync.XDaemon daemon
private URI uriCloseConsumer
private URI uriReceiveNextMsg
private URI uriAcknowledgeMsg
Client client
private long round
private long lastActivity
private long lastMessage
private int nbCnx
public void start(Properties properties, ReliableTransmitter transmitter)
AcquisitionDaemon
start
in interface AcquisitionDaemon
properties
- The initial set of properties.transmitter
- a transmitter used to transmit retrieved messages to the MOM
reliably.private void initFromProperties()
private void createConsumer() throws Exception
Exception
private Message createJSonMessage(HashMap<String,Object> map) throws Exception
Exception
private void closeConsumer()
public void stop()
AcquisitionDaemon
stop
in interface AcquisitionDaemon
public void restart()
public boolean isConnected()
Copyright © 2021 ScalAgent D.T.. All rights reserved.