Page tree

Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Property NameDescriptionRequiredDefault Value
TransportLayer.RMQTA.DescriptionTA DescriptionYRMQ Transport Adaptor
TransportLayer.RMQTA.DllNameTA library file name. libUniversalTADll-gcc44-MD-x64.so should be used.Y
TransportLayer.RMQTA.JVMOptionsFilePath to the TA configuration file nameY
TransportLayer.RMQTA.JavaClassJava class to be used. com.epam.fe.jms.jni.JMSAdaptor should be used.Y

TransportLayer.RMQTA.AllowRejectMessages

When option is true, FE rejects messages if unable to send to the MQ or error was fired. False by default.Nfalse
TransportLayer.RMQTA.AllowRepeatedStatusNotificationWhen option is true, FE allows to call onLogout() callback if no onLogon() callback was called. False by default.Nfalse
TransportLayer.RMQTA.ConnectionNames

Comma delimited list of TA connections.
Separate configuration section for each listed connection should be specified

Y
TransportLayer.RMQTA.ClientNames

Comma delimited list of TA clients.
Separate configuration section for each listed client should be specified

Y
TransportLayer.RMQTA.ClientGroupsComma delimited list of clients group.N
TransportLayer.RMQTA.[GroupName].ClientsComma delimited list of TA clients that are grouped.N
Connection Parameters
TransportLayer.RMQTA.Connection.[ConnectionName].ProviderURI

URI has the following format: amqp://<host>:<port>/<vhost>
Default values: port => 5672; vhost => "/"
For example: «amqp«amqp://localhost»localhost», «amqp«amqp://localhost:8734/vhost»

N
TransportLayer.RMQTA.Connection.[ConnectionName].Addresses

Addresses list. Necessary for clustered solutions to switch between addresses in case of disconnects.

Note, reconnect attempts or intervals are not configurable - when first connection is down, adapter switches to the next connection immediately.

Example:

Code Block
languageperl
titleRMQ.properties
#Addresses list without amqp://
TransportLayer.RMQTA.Connection.rabbit.Addresses = mqprod1:5672, mqprod2:5672

Should be specified one of the parameters - ProviderURI or Addresses.

N
TransportLayer.RMQTA.Connection.[ConnectionName].UserUser nameY
TransportLayer.RMQTA.Connection.[ConnectionName].PasswordUser PasswordY
TransportLayer.RMQTA.Connection.[ConnectionName].ReconnectEnables or disables reconnect procedure for connection restoreNfalse
TransportLayer.RMQTA.Connection.[ConnectionName].ReconnectInterval

Fixed interval in milliseconds between reconnection attempts.

N2000
TransportLayer.RMQTA.Connection.[ConnectionName].ReconnectTriesNumber of reconnect tries or -1 for an infinite number of attemptsN3
Client Parameters
TransportLayer.RMQTA.Client.[ClientName].ConnectionNameName of primary connection used by client. Connection should be registered in ConnectionNames enumeration and has all required parametersY
TransportLayer.RMQTA.Client.[ClientName].SessionType

Session type:

  • Producer - session is a message producer
  • Consumer - session is a message consumer
Y
TransportLayer.RMQTA.Client.[ClientName].DestinationURI

URI of session destination (Queue name). Required for Consumer session type.

For Producer session type should be specified one of the parameters - DestinationURI or ExchangeName - or both of them.

N
TransportLayer.RMQTA.Client.[ClientName].ExchangeName

Name of the Exchange. See RabbitMQ tutorial for details: https://www.rabbitmq.com/tutorials/amqp-concepts.html.

Only for Producer session type. Works with "topic" and "direct" exchange types - on RabbitMQ queues can be bound to an exchange, in this case DestinationURI parameter will be used as routing key.

N
TransportLayer.RMQTA.Client.[ClientName].StorageDirDirectory where persistence file is stored in case the communication problemY
TransportLayer.RMQTA.Client.[ClientName].HeartBeat.EnableIf parameter is true then TA sends and expects HeartBeat messages in configured time intervalNfalse
TransportLayer.RMQTA.Client.[ClientName].HeartBeat.IntervalTime interval in seconds before sending or expecting incoming HeartBeat messageN30
TransportLayer.RMQTA.Client.[ClientName].HeartBeat.MessageFilePath to binary file that contains HeartBeat messageY
TransportLayer.RMQTA.Client.[ClientName].HeartBeat.MissedCountBeforeDisconnectNumber of missed messages before disconnectN3
TransportLayer.RMQTA.Client.[ClientName].MessageProcessingOnMQDisconnect

Type of action that TA executes in case it's unable to deliver outgoing messages to the queue:

  • Save – save in storage file and resend after reconnect
  • Reject – send reject event to FIXEdge
Nreject
TransportLayer.RMQTA.Client.[ClientName].ChannelTransacted

The property turns on transactions to ensure that the messages are stored on the disk.

Values: true | false

NOTE: This property affects performance.

Nfalse
TransportLayer.RMQTA.Client.[ClientName].StartTime

Client start time.
It supports following masks:

  • HH:mm:ss
  • HH:mm
N
TransportLayer.RMQTA.Client.[ClientName].EndTime

Client stop time.
It supports following masks:

  • HH:mm:ss
  • HH:mm
N