public class RESTAcquisition extends Object implements AcquisitionHandler
Modifier and Type | Field and Description |
---|---|
private javax.ws.rs.client.Client |
client |
private String |
destName |
private String |
hostName |
private static org.objectweb.util.monolog.api.Logger |
logger |
private boolean |
mediaTypeJson |
private int |
nbMaxMsg |
private String |
password |
private boolean |
persistent |
private int |
port |
private javax.ws.rs.client.WebTarget |
target |
private long |
timeout |
private URI |
uriCloseConsumer |
private URI |
uriConsume |
private URI |
uriCreateConsumer |
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 org.objectweb.util.monolog.api.Logger logger
private String hostName
private int port
private javax.ws.rs.client.Client client
private javax.ws.rs.client.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 uriCreateConsumer
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 © 2018 ScalAgent D.T.. All Rights Reserved.