java.lang.Object
- com.scalagent.joram.mom.dest.rest.RESTAcquisition

All Implemented Interfaces:

AcquisitionHandler
```
public final class RESTAcquisition
extends Object
implements AcquisitionHandler
```
Simple acquisition handler for the REST acquisition bridge. A Rest/JMS acquisition request is triggered each time a new message is received. If this message contains properties, the module is reinitialized with the incoming properties.

Field Summary

Fields
Modifier and Type	Field	Description
`private jakarta.ws.rs.client.Client`	`client`
`private int`	`connectTimeout`
`private static boolean`	`DEBUG`
`private String`	`destName`
`private String`	`hostName`
`private String`	`idleTimeout`
`private static Logger`	`logger`
`private boolean`	`mediaTypeJson`
`private int`	`nbMaxMsg`
`private String`	`password`
`private boolean`	`persistent`
`private int`	`port`
`private Properties`	`properties`
`private int`	`readTimeout`
`private long`	`timeout`
`private URI`	`uriCloseConsumer`
`private URI`	`uriConsume`
`private boolean`	`useOldAPI`
`private String`	`userName`

Constructor Summary

Constructors
Constructor Description

RESTAcquisition()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Closes the Acquisition module and all associated resources.
`private void`	`closeConsumer()`	Close the consumer.
`private void`	`createConsumer()`	This method is called either from init (implying initialization of the consumer), or retrieve if the consumer is not initialized.
`private HashMap`	`getMapMessage(Map<String,Object> jsonMap)`
`private 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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - logger
```
private static final Logger logger
```
  - DEBUG
```
private static final boolean DEBUG
```
  - properties
```
private Properties properties
```
  - hostName
```
private String hostName
```
  - port
```
private int port
```
  - useOldAPI
```
private boolean useOldAPI
```
  - connectTimeout
```
private int connectTimeout
```
  - readTimeout
```
private int readTimeout
```
  - userName
```
private String userName
```
  - password
```
private String password
```
  - idleTimeout
```
private String idleTimeout
```
  - timeout
```
private long timeout
```
  - persistent
```
private boolean persistent
```
  - nbMaxMsg
```
private int nbMaxMsg
```
  - mediaTypeJson
```
private boolean mediaTypeJson
```
  - destName
```
private String destName
```
  - uriConsume
```
private URI uriConsume
```
  - uriCloseConsumer
```
private URI uriCloseConsumer
```
  - client
```
private jakarta.ws.rs.client.Client client
```
- Constructor Detail
  - RESTAcquisition
```
public RESTAcquisition()
```
- Method Detail
  - init
```
private void init(Properties properties)
```
  - createConsumer
```
private void createConsumer()
                     throws Exception
```
    This method is called either from init (implying initialization of the consumer), or retrieve if the consumer is not initialized.
    
    Throws:
    
    Exception
  - setMessageHeader
```
private void setMessageHeader(Map jsonMessageHeader,
                              Message message)
```
  - getMapMessage
```
private HashMap getMapMessage(Map<String,Object> jsonMap)
                       throws Exception
```
    Throws:
    
    Exception
  - retrieve
```
public void retrieve(ReliableTransmitter transmitter)
              throws Exception
```
    Description copied from interface: AcquisitionHandler
    
    Retrieves one or more message from an external source (e-mail, ftp, ...). Message properties such as priority, expiration or persistence will be set afterwards by the AcquisitionModule.
    
    If the external source is reliable, acknowledgment can be done safely after transmitting the message using the transmitter.
    
    Specified by:
    
    retrieve in interface AcquisitionHandler
    
    Parameters:
    
    transmitter - a transmitter used to transmit retrieved messages to the MOM reliably.
    
    Throws:
    
    Exception
  - setProperties
```
public void setProperties(Properties properties)
```
    Description copied from interface: AcquisitionHandler
    
    Configures the handler with the given properties. This method is called one time before the first call to retrieve and then when the acquisition destination receives a configuration message.
    
    Specified by:
    
    setProperties in interface AcquisitionHandler
    
    Parameters:
    
    properties - The new set of properties.
  - closeConsumer
```
private void closeConsumer()
```
    Close the consumer.
  - close
```
public void close()
```
    Closes the Acquisition module and all associated resources. Called by generic behavior during the destination finalization.
    
    Specified by:
    
    close in interface AcquisitionHandler

Class RESTAcquisition

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

DEBUG

properties

hostName

port

useOldAPI

connectTimeout

readTimeout

userName

password

idleTimeout

timeout

persistent

nbMaxMsg

mediaTypeJson

destName

uriConsume

uriCloseConsumer

client

Constructor Detail

RESTAcquisition

Method Detail

init

createConsumer

setMessageHeader

getMapMessage

retrieve

setProperties

closeConsumer

close