Added configuration option for auto reconnect, reconnect delay, and max inflight

[syedmhashim]

Purpose

Resolves Issue: Resolve Auto Reconnect in MQTT

Goals

Provide capability to configure:

• Automatic reconnect
• Reconnect delay
• Max inflight

Approach

Using siddhi parameters annotation to add configurations for automatic reconnect, reconnect delay, and max inflight, as done for the rest of the configuration parameters.
The PR also includes integration tests for automatic reconnect.

User stories

NA

Release note

This release includes the adding configuration parameters for mqtt client that would allow the users to configure automatic reconnect, reconnect delay and max inflight.

Documentation

NA

Training

NA

Certification

NA

Marketing

NA

Automation tests

• Integration tests
  • mqttPublishEventWithAutomaticReconnect
  • mqttPublishEventWithoutAutomaticReconnect
  • mqttReceiveEventsWithAutomaticReconnect
  • mqttReceiveEventsWithoutAutomaticReconnect

Security checks

• Followed secure coding standards in http://wso2.com/technical-reports/wso2-secure-engineering-guidelines? yes/no
• Ran FindSecurityBugs plugin and verified report? yes
• Confirmed that this PR doesn't commit any keys, passwords, tokens, usernames, or other secrets? yes

Samples

Sample mqttsource siddhi script

@app:name('test')

@source(
type='mqtt',
url='tcp://localhost:1883',
topic='test/tag1',
automatic.reconnect='true',
clean.session='false'
@map(type='json'))
define stream BarStream (id string);

from BarStream#log()
select *
insert into test;

Sample mqttsink siddhi script

@app:name('test')

define trigger Mytrigger at every 5 sec;

@sink(
type='mqtt',
url='tcp://localhost:1883',
topic='test/tag1',
automatic.reconnect='true',
@map(type='json'))
define stream FooStream (id string);

from Mytrigger
select "testing..." as id
insert into FooStream;

Related PRs

NA

Migrations (if applicable)

NA

Test environment

• JDK version: 1.8.0_231
• Maven version: 3.5.0
• OS: Linux
• Architecture: x86_64
• Cores: 4

Learning

NA

[webfrank]

Hi, I've made similar changes plus re-subscribe to topic when reconnecting. Please merge this PR so I can rebase mine with resubscribe patch.

[syedmhashim]

Hi, I've made similar changes plus re-subscribe to topic when reconnecting. Please merge this PR so I can rebase mine with resubscribe patch.

Hi @webfrank. I cannot merge this PR unless I have 1 approving review.