public class RestAcquisitionAsync extends Object implements AcquisitionDaemon
Modifier and Type | Class and Description |
---|---|
private class |
RestAcquisitionAsync.XDaemon |
Modifier and Type | Field and Description |
---|---|
(package private) javax.ws.rs.client.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 static org.objectweb.util.monolog.api.Logger |
logger |
private boolean |
mediaTypeJson |
private String |
password |
private boolean |
persistent |
private int |
port |
private Properties |
properties |
private int |
readTimeout |
private String |
timeout |
private ReliableTransmitter |
transmitter |
private URI |
uriAcknowledgeMsg |
private URI |
uriCloseConsumer |
private URI |
uriReceiveNextMsg |
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.
|
private Message |
recvNextMessage() |
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 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 RestAcquisitionAsync.XDaemon daemon
private URI uriCloseConsumer
private URI uriReceiveNextMsg
private URI uriAcknowledgeMsg
javax.ws.rs.client.Client client
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
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.