public class RESTAcquisition extends Object implements AcquisitionHandler
Modifier and Type | Field and Description |
---|---|
private Client |
client |
private String |
destName |
private String |
hostName |
private static Logger |
logger |
private boolean |
mediaTypeJson |
private int |
nbMaxMsg |
private String |
password |
private boolean |
persistent |
private int |
port |
private WebTarget |
target |
private long |
timeout |
private URI |
uriCloseConsumer |
private URI |
uriConsume |
private boolean |
useOldAPI |
private String |
userName |
Constructor and Description |
---|
RESTAcquisition() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this handler and releases any system resources associated to it.
|
void |
createConsumer() |
private Map |
getMapMessage(Map<String,Object> jsonMap) |
void |
init(Properties properties) |
void |
retrieve(ReliableTransmitter transmitter)
Retrieves one or more message from an external source (e-mail, ftp, ...).
|
private void |
setMessageHeader(Map jsonMessageHeader,
Message message) |
void |
setProperties(Properties properties)
Configures the handler with the given properties.
|
private static final Logger logger
private String hostName
private int port
private boolean useOldAPI
private Client client
private WebTarget target
private String userName
private String password
private long timeout
private boolean persistent
private int nbMaxMsg
private boolean mediaTypeJson
private String destName
private URI uriConsume
private URI uriCloseConsumer
public void init(Properties properties)
public void createConsumer()
private Map getMapMessage(Map<String,Object> jsonMap) throws Exception
Exception
public void retrieve(ReliableTransmitter transmitter) throws Exception
AcquisitionHandler
AcquisitionModule
.retrieve
in interface AcquisitionHandler
transmitter
- a transmitter used to transmit retrieved messages to the MOM
reliably.Exception
public void setProperties(Properties properties)
AcquisitionHandler
setProperties
in interface AcquisitionHandler
properties
- The new set of properties.public void close()
AcquisitionHandler
close
in interface AcquisitionHandler
Copyright © 2022 ScalAgent D.T.. All rights reserved.