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

All Implemented Interfaces:

AcquisitionDaemon
```
public final class RestAcquisitionAsync
extends Object
implements AcquisitionDaemon
```
Asynchronous acquisition handler implementing the AcquisitionDaemon interface.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`private class`	`RestAcquisitionAsync.CheckTask`	Task checking the acquisition mechanism.
`private class`	`RestAcquisitionAsync.XDaemon`	Daemon for acquisition mechanism.

Field Summary

Fields
Modifier and Type	Field	Description
`private long`	`checkPeriod`
`private TimerTask`	`checkTask`
`(package private) jakarta.ws.rs.client.Client`	`client`
`private static int`	`CLIENT_ACKNOWLEDGE`	Duplicates JMS definition to avoid a useless dependency.
`private String`	`clientId`
`private int`	`connectTimeout`
`private String`	`consName`
`private RestAcquisitionAsync.XDaemon`	`daemon`
`private static boolean`	`DEBUG`
`private String`	`destName`
`private String`	`hostName`
`private String`	`idleTimeout`
`private long`	`lastActivity`
`private long`	`lastMessage`
`private static 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 Summary

Constructors
Constructor Description

RestAcquisitionAsync()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`private void`	`acknowledgeMessage()`
`private void`	`closeConsumer()`	Close the consumer.
`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 boolean`	`isConnected()`
`private Message`	`recvNextMessage()`
`private 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.

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
```

CLIENT_ACKNOWLEDGE
```
private static final int CLIENT_ACKNOWLEDGE
```
Duplicates JMS definition to avoid a useless dependency.

See Also:

Constant Field Values

properties
```
private Properties properties
```

transmitter

private ReliableTransmitter transmitter

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
```

destName
```
private String destName
```

consName
```
private String consName
```

clientId
```
private String clientId
```

idleTimeout
```
private String idleTimeout
```

timeout
```
private String timeout
```

mediaTypeJson
```
private boolean mediaTypeJson
```

persistent
```
private boolean persistent
```

checkPeriod
```
private long checkPeriod
```

checkTask
```
private TimerTask checkTask
```

daemon

private RestAcquisitionAsync.XDaemon daemon

uriCloseConsumer
```
private URI uriCloseConsumer
```

uriReceiveNextMsg
```
private URI uriReceiveNextMsg
```

uriAcknowledgeMsg
```
private URI uriAcknowledgeMsg
```

client
```
jakarta.ws.rs.client.Client client
```

round
```
private long round
```

lastActivity
```
private long lastActivity
```

lastMessage
```
private long lastMessage
```

nbCnx
```
private int nbCnx
```

Constructor Detail
- RestAcquisitionAsync
```
public RestAcquisitionAsync()
```

Method Detail

start
```
public void start(Properties properties,
                  ReliableTransmitter transmitter)
```
Description copied from interface: AcquisitionDaemon

Tells the daemon to start with the given properties.

Specified by:

start in interface AcquisitionDaemon

Parameters:

properties - The initial set of properties.

transmitter - a transmitter used to transmit retrieved messages to the MOM reliably.

initFromProperties
```
private void initFromProperties()
```
Initializes fields from properties.

createConsumer
```
private void createConsumer()
                     throws Exception
```
Gets destination and initializes the Rest/JMS consumer.

Throws:

Exception

recvNextMessage

private Message recvNextMessage()
                         throws Exception

Throws:: Exception

getPropertyValue

private Object getPropertyValue(String type,
                                String value)

setJMSMessageHeader

private void setJMSMessageHeader(Message msg,
                                 Map header)

setJMSProperties

private void setJMSProperties(Message msg,
                              Map props)

getMapMessage

private Map<String,Object> getMapMessage(Map<String,Object> jsonMap)

createJSonMessage

private Message createJSonMessage(HashMap<String,Object> map)
                           throws Exception

Throws:: Exception

createTextMessage

private Message createTextMessage(String text)
                           throws Exception

Throws:: Exception

acknowledgeMessage

private void acknowledgeMessage()
                         throws Exception

Throws:: Exception

closeConsumer
```
private void closeConsumer()
```
Close the consumer.

stop
```
public void stop()
```
Description copied from interface: AcquisitionDaemon

Tells the daemon to stop. Any system resources previously allocated must be released.

Specified by:

stop in interface AcquisitionDaemon

restart
```
private void restart()
```

isConnected
```
private boolean isConnected()
```

Class RestAcquisitionAsync

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

DEBUG

CLIENT_ACKNOWLEDGE

properties

transmitter

hostName

port

useOldAPI

connectTimeout

readTimeout

userName

password

destName

consName

clientId

idleTimeout

timeout

mediaTypeJson

persistent

checkPeriod

checkTask

daemon

uriCloseConsumer

uriReceiveNextMsg

uriAcknowledgeMsg

client

round

lastActivity

lastMessage

nbCnx

Constructor Detail

RestAcquisitionAsync

Method Detail

start

initFromProperties

createConsumer

recvNextMessage

getPropertyValue

setJMSMessageHeader

setJMSProperties

getMapMessage

createJSonMessage

createTextMessage

acknowledgeMessage

closeConsumer

stop

restart

isConnected