Versions Compared

Key

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

...

Sv translation
languageja


Tip

Learn more about Sender module functions. モジュールの機能についてはこちらをご覧ください。

Running module

Sender can be started using the provided starting script, automatically when installed using the installer or manually, by executing following command:Senderは、付属の起動スクリプト、インストーラによるインストール時の自動起動、または以下のコマンドを実行することにより手動で起動することができます:

Code Block
language bash
java -Dapplication.name=sender-1 -Dfile.encoding=UTF8 -jar iot-collector-generic-sender-x.y.z.jar

This command will start the sender with the default configuration of the cluster and audit. If necessary, it is also possible to manually specify these files:このコマンドは、クラスタと監査のデフォルト構成でSenderを開始します。必要であれば、これらのファイルを手動で指定することも可能です:

Code Block
language bash
java -Dapplication.name=sender-1 -Dvertx.hazelcast.config=cluster.xml -Dfile.encoding=UTF8 -jar iot-collector-generic-sender-x.y.z.jar -conf config.json

Runtime parameters explained

Parameter nameDescriptionExample
-Dapplication.name
Mandatory JVM parameter. Defines the name of the sender.
JVMの必須パラメータです。Senderの名前を定義します。
-Dapplication.name=sender-1
-Dvertx.hazelcast.config
Optional JVM
parameter. Specifies the file containing the cluster configuration.オプションのJVMパラメータです。クラスタ構成を含むファイルを指定します。
-Dvertx.hazelcast.config=cluster.xml
-Dfile.encoding
Optional JVM parameter
. Specifies the encoding used when working with byte streams or reading messages and files.オプションのJVMパラメータです。バイトストリームを扱うとき、あるいはメッセージやファイルを読み込むときに使用するエンコーディングを指定します。
-Dfile.encoding=UTF8
-jar
Specifies the Controller JAR file to be started.起動するController JARファイルを指定します。
-jar iot-collector-generic-sender-x.y.z.jar
-conf
Specifies the module configuration fileモジュール構成ファイルを指定します。
-conf config.json


Configuration

Configuration is provided in config.json, which is passed to the application as -conf parameter

設定はconfig.jsonで行い、それを-confパラメータとしてアプリケーションに渡します。

Info
オプションはドット表記で、ドットはネストした状態を表します
Info
Options are listed in dot notation - dot is refering to nested enttiy (e.g.   senders[].license  means  { "senders" :  [ { "license"  : "abcdefgh" } ] }


Tip

It is possible to run multiple senders using single JAR - by defining multiple receivers in senders array. See below.Senders配列に複数のReceiverを定義することで、1つのJARで複数のSenderを動作させることが可能です。 以下を参照してください。

Common options

Option/EntityTypeDefaultDescription
senders
Array of objectsArray of senders configuration.
Senderの設定の配列。
senders[].license
StringemptyLicense provided by BellaDatiライセンスはBellaDatiが提供します。
senders[].name
StringemptyName of the moduleモジュール名
senders[].host
StringlocalhostHTTP host on which HTTP endpoints are runningHTTPエンドポイントが動作しているHTTPホスト
senders[].port
Integer8101HTTP port on which HTTP endpoints are runningHTTPエンドポイントが動作しているHTTPポート
senders[].source
Object

Contains source receiver configuration.Receiver の設定値が含まれています。

senders[].source.receiver
String
Identification of associated receiver関連するReceiverの特定
senders[].source.inputMode
StringSINGLE

Data input modeデータ入力モード:

  • SINGLE - message payload contains only single recordメッセージのペイロードが単一のレコードのみを含みます
  • BULK - message payload contains multiple recordsメッセージのペイロードが複数のレコードを含みます

Receiver の設定に対応する必要があります。Must correspond to the receiver's configuration.

senders[].source.dataElement
StringdataSpecifies BULKモードの "data " element path in BULK mode要素パスを指定します。
senders[].source.auth
Object
Contains authentication configuration認証設定を含みます。
senders[].source.auth.enabled
BooleantrueFlag indicating if Basic authentication is configured on receiverReceiver に Basic 認証が設定されているか否かを示すフラグ
senders[].source.auth.username
StringUsername (as defined in receiver's configuration)
ユーザー名(Receiver の設定による)
senders[].source.auth.password
StringPlain text password (as defined in receiver's configuration)
プレインテキスト形式のパスワード(Receiver の設定により定義さ れます)。
senders[].bodyLimit
Integer2097152Maximum allowed request body size (in bytes)リクエストボディの最大許容サイズ(単位:バイト)
senders[].period
Integer60Delay (in seconds) after which the timer will fire new send eventタイマーが新しい送信イベントを発生させるまでの遅延時間(秒)
senders[].startId
Integer-1Start ID that is used as a filter to obtain data from receiver (HSQL iterates from 0)受信機からデータを取得する際のフィルタとして使用する開始 ID(HSQL では 0 から繰り返し)
senders[].limit
Integer1000Page size that is used as a filter to obtain data from receiverReceiverからデータを取得する際のフィルタとして使用するページサイズ
senders[].deleteProcessed
BooleantrueFlag indicating if processed data should be deleted from receiver databaseReceiverデータベースから処理済データを削除するか否かを示すフラグ。
senders[].actions
Array of strings

Specifies the automated action type. Available options are:自動化されたアクションの種類を指定します。利用可能なオプションは次のとおりです:

  • BELLADATI_REST - sends data to BellaDati backend
  • HTTP_REQUST - creates HTTP request
  • MQTT_PUBLISH - publish message to MQTT server
  • EMAIL - sends email
  • SAVE_TO_FILE - saves data to file
senders[].actionRules
Object
Contains action rules configurationアクションルールの設定が含まれます
senders[].actionRules.filterRules
Array of objectsContains filter rules configuration objects
フィルタルール設定オブジェクトが含まれます
senders[].actionRules.filterRules.field
String
Name of the field within the normalized message.正規化されたメッセージ内のフィールドの名前
senders[].actionRules.filterRules.operation
String

Compare operation type. Available operations:操作の種類を比較します。利用可能な操作:

  • BETWEEN
  • EQ
  • GT
  • GTE
  • IN
  • LT
  • LTE
  • NEQ
  • NOT_IN
  • NOT_NULL
  • NULL
senders[].actionRules.filterRules.values
Array of stringsArray of values to filter.
フィルタリングする値の配列。
senderssenders[].transformationObject
Contains transformation configuration. Not included if no transformation is used.変換設定が含まれています。トランスフォームを使用しない場合は含まれません。
senders[].transformation.typeStringFFTType

使用される変換の種類。利用可能なオプション:

"fft

of transformation which is used. Available options: "FFT

" & "

PEEK2PEEK

peek2peek"

senders[].transformation.fieldsStringx,yCollected elemetns which should be transformed separated with comma.コンマで区切られた変換すべきエレメントを集めたもの
senders[].transformation.samplingFrequencyInteger1000Available only for transformation type 変換タイプ "FFT ". Otherwise should not be included.の場合のみ有効です。それ以外の場合は含まれません。
senders[].db
Object
Contains database configuration. You can keep the default values unless you use some specific database.データベースの設定が含まれています。特定のデータベースを使用しない限り、デフォルト値のままで構いません。
senders[].db.url
Stringjdbc:hsqldb:file:hsql/instance-db;shutdown=trueDatabase connection stringデータベース接続文字
senders[].db.user
StringSADatabase usernameデータベースユーザー名
senders[].db.password
StringemptyDatabase passwordデータベースパスワード
senders[].db.driverclass
Stringorg.hsqldb.jdbcDriverDatabase JDBC driver classデータベースJDBCドライバクラス
senders[].db.max_pool_size
Integer100Database maximum pool sizeデータベース最大プールサイズ
senders[].db.drop
BooleanfalseFlag indicating if database should be dropped during module startupモジュール起動時にデータベースを削除するかどうかを示すフラグ
senders[].auth
Object
Configuration of administrators common for all modules全モジュール共通の管理者設定
senders[].auth.enabled
BooleantrueFlag indicating if administrator authentication is enabled管理者認証が有効であるかどうかを示すフラグ
senders[].auth.drop
BooleanfalseFlag indicating if administrators should be dropped during module startupモジュール起動時に管理者を削除するかどうかを示すフラグ
senders[].auth.merge
BooleantrueFlag indicating if administrators should be merged during module startupモジュール起動時に管理者の統合を行うかどうかを示すフラグ
senders[senders[].auth.users
ArrayArray of administrators to merge (insert new or update existing)
マージする管理者の配列(新規挿入または既存更新)
senders[].auth.users.username
StringadminUnique usernameユニークユーザー名
senders[].auth.users.password
String
Hashed password if 'salt' is defined, otherwise plain text password‘salt' が定義されている場合はハッシュ化されたパスワード、そうでない場合はプレーンテキストパスワード
senders[].auth.users.salt
String
Salt used to hash passwordパスワードのハッシュ化に使用する`salt`
senders[].auth.users.roles
String array[ "VIEWER" ]Array of user rolesユーザーロールの配列

Send data to BellaDati action options

If senders[].actions contains BELLADATI_REST, following options are available:

Option/EntityTypeDefaultDescription
senders[].belladati
ObjectObject containing sending data to BellaDati configuration
BellaDatiのコンフィギュレーションへの送信データを含むオブジェクト
senders[].belladati.url
Stringhttps://service.belladati.comBellaDati URL
senders[].belladati.useSsl
BooleantrueFlag indicating if BellaDati is running on SSL portBellaDatiがSSLポートで動作しているかどうかを示すフラグ
senders[].belladati.consumerKey
String
OAuth consumer keyOAuthコンシューマキー
senders[].belladati.consumerSecret
String
OAuth consumer secretコンシューマーシークレット
senders[].belladati.username
String
BellaDati usernameユーザーネーム
senders[].belladati.password
String
BellaDati passwordパスワード
senders[].belladati.dataSet
Object
Destination data set configurationデスティネーションデータセット構成
senders[].belladati.dataSet.id
IntegerID
of the destination data set, where data should be importedデータをインポートする先のData setのID
senders[].belladati.dataSet.columnId
String
Code of attribute/indicator that contains record identificationレコードの識別を含む属性/指標のコード
senders[].belladati.dataSet.columnReceiver
StringCode of attribute/indicator that contains receiver identification
Receiver Identification を含む属性/指標を示すコード。
senders[].belladati.dataSet.columnJson
String
Code of attribute/indicator that contains JSON dataJSONデータを含む属性/インジケータのコード
senders[].belladati.dataSet.columnTimestamp
String
Code of attribute/indicator that contains timestampタイムスタンプを含む属性/指標のコード
senders[].belladati.dataSet.jsonMapping
String
List of mappings between BellaDati indicator/attribute code and JSON keyBellaDatiのインジケーター/属性コードとJSONキーとの対応表です。
senders[].belladati.dataSet.templateId
Integer
ID of import template, which should be used while executing the importインポート実行時に使用されるインポートテンプレートのID
senders[].belladati.dataSet.splitByColumn
Integer
Index of column used to split dataデータ分割に使用した列のインデックス
senders[].belladati.continueOnError
BooleanfalseDetermines whether to continue or not if error occursエラー発生時に処理を続行するかどうかを確定します。

HTTP request action options

If senders[].actions contains HTTP_REQUEST, following options are available:

Option/EntityTypeDefaultDescription
senders[].httpRequset
Object
Object containing HTTP_REQUST action configuration options.アクションの設定オプションが含まれるオブジェクト。
senders[].httpRequest.url
String
URL where the request will be sentリクエストの送信先URL
senders[].httpRequest.method
StringPOST

HTTP method. Available options are:HTTPメソッド。利用可能なオプションは以下の通りです:

  • POST
  • GET
  • DELETE
  • PUT
senders[].httpRequest.headers
String
HTTP headers
senders[].httpRequest.content
StringHTTP request payload. It's possible to reference any of fields received from receiver.
HTTPリクエストのペイロード。Receiver から受け取った任意のフィールドを参照することが可能です。
 
enders[].httpRequest.sendAsForm
BooleanfalseEnables URL-encoding of the data, similar to -cUrlの-data-urlencode from cUrl.urlencodeと同様に、データのURLエンコードを有効にします。
senders[].httpRequest.continueOnError
BooleanfalseDetermines whether to continue or not if error occursエラー発生時に処理を続行するかどうかを決定します。
senders[].httpRequest.auth
Object
Contains authentication options.認証オプションが含まれます。
senders[].httpRequest.auth.type
StringBASIC

Type of the authentication. Available options are:認証の種類。利用可能なオプションは次のとおりです:

  • BASIC
  • DIGEST
  • OAUTH
senders[].httpRequest.auth.useSsl
BooleantrueFlag indicating if server is running on SSL portサーバがSSLポートで動作しているかどうかを示すフラグ
senders[].httpRequest.auth.consumerKey
String
OAuth consumer keyOAuthコンシューマキー
senders[].httpRequest.auth.consumerSecret
String
OAuth consumer secretコンシューマーシークレット
senders[].httpRequest.auth.username
String
Usernameユーザーネーム
senders[].httpRequest.auth.password
String
Passwordパスワード

MQTT publish action options

If senders[].actions contains MQTT_PUBLISH, following options are available:

Option/EntityTypeDefaultDescription
senders[].mqttPublish
Object
Provides configuration for MQTT_PUBLISH automated action.自動アクションの設定を提供します。
senders[].mqttPublish.host
StringlocalhostHost on which MQTT server is running.MQTTサーバーが動作しているホスト
senders[].mqttPublish.port
Integer1883Port on which MQTT server is running.MQTTサーバーが動作しているポート
senders[].mqttPublish.topic
String#MQTT topic to publish to - wildcards (+ and #) are supportedMQTTトピックの発行先 - ワイルドカード(+と#)を使用できます。
senders[].mqttPublish.qos
StringAT_MOST_ONCEQuality of service. Available options: サービスのクオリティ 利用できるオプション: AT_LEAST_ONCE, AT_MOST_ONCE, EXACTLY_ONCE, FAILURE
senders[].mqttPublish.content
String
HTTP request payload. It's possible to reference any of fields received from receiver.HTTPリクエストのペイロード。受信機から受け取ったフィールドを参照することが可能です。
senders[].mqttPublish.continueOnError
BooleanfalseDetermines whether to continue or not if error occursエラー発生時に処理を続行するかどうかを決定します。
senders[].mqttPublish.receiveBufferSize
Integer
Set the TCP receive buffer size.TCP受信バッファーのサイズを設定します。
senders[].mqttPublish.timeoutOnConnect
Integer120Set the timeout on CONNECT packet in seconds.CONNECTパケットのタイムアウトを秒単位で設定します。
senders[].mqttPublish.maxMessageSize
Integer-1Set max MQTT message size in bytes.MQTTメッセージの最大サイズをバイト単位で設定します。
senders[].mqttPublish.autoClientId
BooleanfalseSet if clientid should be auto-generated when it's "zero-bytes"の時にclientidを自動生成するかどうかを設定します。
senders[].mqttPublish.tcpNoDelay
BooleanfalseSet whether TCP no delay is enabledTCP 無遅延を有効にするかどうかを設定します。
senders[].mqttPublish.tcpKeepAlive
BooleanfalseSet whether TCP keep alive is enabledTCPキープアライブが有効かどうかを設定します。
senders[].mqttPublish.soLinger
BooleanfalseSet whether SO_linger keep alive is enabledlingerのキープアライブが有効かどうかを設定する。
senders[].mqttPublish.acceptBacklog
Integer1024Set the accept back logアクセプトバックログを設定します。
senders[].mqttPublish.useAlpn
BooleanfalseSet the ALPN usage.ALPNの使用方法を設定します。
senders[].mqttPublish.logActivity
BooleanfalseSet to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.ネットワーク活動のロギングを有効にするにはtrueを設定します。Nettyのパイプラインは、Nettyのロガーでログを取るように設定されています。
senders[].mqttPublish.trafficClass
Integer-1Set the value of traffic classトラフィッククラスの値を設定します
senders[].mqttPublish.idleTimeout
Integer-1Set the idle timeout, in seconds.アイドルタイムアウトを秒単位で設定します。
senders[].mqttPublish.sendBufferSize
Integer-1Set the TCP send buffer sizeTCP送信バッファーのサイズを設定します。
senders[].mqttPublish.usePooledBuffers
BooleanfalseSet whether Netty pooled buffers are enabledNettyのプールバッファが有効かどうかを設定します。
senders[].mqttPublish.clientAuth
StringNONE
  • NONE
  • REQUEST - Accept authentication if presented by client. If this option is set and the client chooses not to provide authentication information about itself, the negotiations will continue.クライアントから提示された場合、認証を受け入れる。このオプションが設定され、クライアントが自分自身の認証情報を提供しないことを選択した場合、交渉は続行されます。
  • REQUIRED - クライアントに認証の提示を要求し、提示がない場合は交渉を拒否します。REQUIRED - Require client to present authentication, if not presented then negotiations will be declined.
senders[].mqttPublish.auth
Object
Defines the authentication options認証オプションを定義します
senders[].mqttPublish.auth.ssl
BooleanfalseSet whether SSL/TLS is enabledTLSが有効かどうかを設定します。
senders[].mqttPublish.auth.type
String

Authentication type. Available options:認証の種類です。利用可能なオプションです:

  • BASIC
  • DIGEST
  • CLIENT_CERT
senders[].mqttPublish.auth.keystorePath
String
Absolute path to Java keystore file Javaキーストアファイル(JKS)への絶対パス
senders[].mqttPublish.auth.keystorePassword
String
Password of Java keystorekeystoreのパスワード
senders[].mqttPublish.auth.clientCert
String
Client certificate nameクライアント証明書名/aliasエイリアス
senders[].mqttPublish.auth.username
String
Usernameユーザーネーム
senders[].mqttPublish.auth.password
String
Passwordパスワード

Send email action options

If senders[].actions contains EMAIL, following options are available:

Option/EntityTypeDefaultDescription
senders[].email
Object
Provides configuration for EMAIL automated action.EMAILの自動化されたアクションのための設定を提供します。
senders[].email.host
StringlocalhostHost on which SMTP server is running.SMTPサーバーが稼働しているホスト
senders[].email.port
Integer25Port on which SMTP server is running.SMTPサーバーが動作しているポート
senders[].email.content
StringEmail
content. It's possible to reference any of fields received from receiver.メールの内容です。Receiver から受信した任意のフィールドを参照することが可能です。
senders[].email.sender
String
Email sender
senders[].email.subject
StringEmail
subject. It's possible to reference any of fields received from receiver.メールの件名: 受信機から受信した任意のフィールドを参照することが可能です。
senders[].email.recipients
Array of stringsArray of email recipients
メール受信者の配列
senders[].email.continueOnError
BooleanfalseDetermines whether to continue or not if error occursエラー発生時に処理を続行するかどうかを決定します。
senders[].email.auth
Object
Defines the SMTP server authentication optionsSMTPサーバーの認証オプションを定義します。
senders[].email.auth.useSsl
BooleanfalseSet whether SSL/TLS is enabledTLSが有効かどうかを設定します。
senders[].email.auth.username
String
SMTP server usernameSMTPサーバーのユーザー名
senders[].email.auth.password
StringSMTP
server PasswordSMTPサーバー パスワード

Configuration sample

Code Block
linenumbers true
collapse true
{
  "senders": [                                                  -> JSON array containing configuration of multiple receivers
    {
      "license": "n5NkzaEOALzvGs7LOExyAulYdqo8X+5==",           -> License key
      "name": "Sender 01",                                      -> Sender identification
      "source": {                                               -> Source receiver definition
        "receiver": "Receiver 01",                              -> Identification of associated receiver
        "inputMode": "SINGLE",                                  -> Data input mode (see Enumerations below)
        "httpClientConfig": {                                   -> Optional Vert.x HttpClientOptions for HttpClient (see receiver's configuration)
          "keepAlive": true,                                    -> Set whether keep alive is enabled
          "pipelining": false,                                  -> Set whether pipe-lining is enabled
          "ssl": true,                                          -> Set whether SSL/TLS is enabled
          "trustAll": true,                                     -> Set whether all server certificates should be trusted
          "maxPoolSize": 25,                                    -> Set the maximum pool size for connections
          "idleTimeout": 3,                                     -> Set the idle timeout, in seconds (zero means don't timeout)
          "connectTimeout": 5000,                               -> Set the connect timeout, in milliseconds
          "maxWaitQueueSize": -1                                -> Set the maximum requests allowed in the wait queue (-1 means unbounded)
          ...                                                   -> Other: http://vertx.io/docs/apidocs/io/vertx/core/http/HttpClientOptions.html
        },
        "auth": {
          "enabled": true,                                      -> Flag indicating if Basic authentication is configured on receiver
          "username": "editor",                                 -> Username (see receiver's configuration)
          "password": "BellaDati01",                            -> Plain text password (see receiver's configuration)
        }
      },
      "host": "localhost",                                      -> HTTP host on which HTTP endpoints are running
      "port": 8101,                                             -> HTTP port on which HTTP endpoints are running
      "bodyLimit": 2097152,                                     -> Maximum allowed request body size (in bytes, default: 2 MB)
      "period": 60,                                             -> Delay (in seconds) after which the timer will fire new send event
      "startId": -1,                                            -> Start ID that is used as a filter to obtain data from receiver (HSQL iterates from 0)
      "limit": 1000,                                            -> Page size that is used as a filter to obtain data from receiver
      "saveToFile": true,                                       -> Deprecated - use actions instead. Flag indicating if transformed data should be saved to local file
      "sendToBellaDati": true,                                  -> Deprecated - use actions instead. Flag indicating if transformed data should be send to BellaDati
      "deleteProcessed": true,                                  -> Flag indicating if processed data should be deleted from receiver database
      "actions" : [ "BELLADATI_REST", "EMAIL" ],                -> Specifies the sender type. Available types: BELLADATI_REST, HTTP_REQUEST, MQTT_PUBLISH, EMAIL, SAVE_TO_FILE;
      "belladati": {                                            -> BellaDati configuration
        "url": "http://localhost:8081/",                        -> BellaDati URL
        "useSsl": false,                                        -> Flag indicating if BellaDati is running on SSL port
        "consumerKey": "apiKey",                                -> OAuth consumer key
        "consumerSecret": "apiSecret",                          -> OAuth consumer secret
        "username": "dadmin01",                                 -> BellaDati username
        "password": "BellaDati01",                              -> BellaDati password
        "dataSet": {                                            -> DataSet configuration
          "id": "123",                                          -> DataSet identification
          "columnId": "M_ID",                                   -> Code of attribute/indicator that contains record identification
          "columnReceiver": "L_RECEIVER",                       -> Code of attribute/indicator that contains receiver identification
          "columnJson": "L_JSON",                               -> Code of attribute/indicator that contains JSON data
          "columnTimestamp": "L_TIMESTAMP",                     -> Code of attribute/indicator that contains timestamp
          "jsonMapping": "M_IND1=ind1_json,L_ATTR1=attr1_json", -> List of mappings between BellaDati indicator/attribute code and JSON key
          "templateId": 12345,                                  -> Identification of import template
          "splitByColumn": 4                                    -> Index of column used to split data
        },
        "continueOnError" : false
      },
      "httpRequest" : {
        "url" : "http://host",
        "method" : "POST"|"GET"|"DELETE"|"PUT",
        "headers" : "header1=value1,header2=value2",
        "auth" : {
          "type" : "BASIC",                                     -> Auth type: BASIC, DIGEST, OAUTH
          "useSsl": false,                                      -> Flag indicating if BellaDati is running on SSL port
          "consumerKey": "apiKey",                              -> OAuth consumer key
          "consumerSecret": "apiSecret",                        -> OAuth consumer secret
          "username": "dadmin01",                               -> BellaDati username
          "password": "BellaDati01"                             -> BellaDati password
        },
        "continueOnError" : false,
        "content" : "Message content with variables"            -> It's possible to reference any of fields received from receiver
      },
      "mqttPublish" : {
        "host" : "host",
        "port" : 1833,
        "topic" : "topic/to/publish/to",
        "qos" : "AT_LEAST_ONCE",                                -> Quality of service AT_LEAST_ONCE, AT_MOST_ONCE, EXACTLY_ONCE, FAILURE
        "auth" : {
          "type" : "BASIC",                                     -> Auth type: BASIC, DIGEST, CLIENT_CERT
          "useSsl": false,                                      -> Flag indicating if BellaDati is running on SSL port
          "keystorePath": "/path/to/server-keystore.jks",       -> Absolute path to Java keystore file (JKS)
          "keystorePassword": "wibble",                         -> Password of Java keystore
          "clientCert": "certName",                             -> OAuth consumer key
          "username": "dadmin01",                               -> BellaDati username
          "password": "BellaDati01"                             -> BellaDati password
        },        
        "content" : "Message content with variables",           -> It's possible to reference any of fields received from receiver
        "continueOnError" : false,
        "options" : {
          "receiveBufferSize" : 123456,                         -> Set the TCP receive buffer size
          "timeoutOnConnect" : 120,                             -> Set the timeout on CONNECT packet
          "maxMessageSize" : -1,                                -> Set max MQTT message size
          "autoClientId" :  false,                              -> Set if clientid should be auto-generated when it's "zero-bytes"
          "tcpNoDelay" : false,                                 -> Set whether TCP no delay is enabled
          "tcpKeepAlive" : false,                              	-> Set whether TCP keep alive is enabled
          "soLinger" : false,
          "tcpQuickAck" : false,
          "tcpFastOpen" : false,
          "tcpCork" : false,
          "acceptBacklog" : false,
          "useAlpn" : false,
          "clientAuth" : false,
          "logActivity" : false,
          "trafficClass" : -1,
          "idleTimeout" : -1,
          "sendBufferSize" :  -1,
          "usePooledBuffers" : false,
          "clientAuthRequired" :  false, 
          "enabledSecureTransportProtocols" :  false
        }
      },
      "email" : {
        "host" : "smtp_host",
        "port" : 25,
        "auth" : {
          "useSsl": false,                                      -> Flag indicating if SMTP is running on SSL port
          "username": "dadmin01",                               -> SMTP username
          "password": "BellaDati01"                             -> SMTP password
        },
        "sender"  : "sender@email.com",
        "subject" : "Subject of the email",                     -> It's possible to reference any of fields received from receiver
        "content" : "Message content with variables",            -> It's possible to reference any of fields received from receiver
        "continueOnError" : false
      },
      "actionRules" : {
          "field1": {
              "op": "EQ",
              "value": "Slovakia"
          },
          "field2": {
              "op": "IN",
              "values": [ "Type 1", "Type 2", "Type 3" ]
          },
          "field3": {
              "op": "NOT_NULL"
          },
          "field4": {
              "op": "GT",
              "value" : 1200
          }
      }
      "db": {                                                             -> Database configuration
        "url": "jdbc:hsqldb:file:/path/to/my-sender01-db;shutdown=true",  -> Database connection string
        "user": "SA",                                                     -> Database username
        "password": "",                                                   -> Database password
        "driverclass": "org.hsqldb.jdbcDriver",                           -> Database JDBC driver class (see dependencies in pom.xml)
        "max_pool_size": 100,                                             -> Database maximum pool size
        "drop": true                                                      -> Flag indicating if database should be dropped during module startup
      },
      "auth": {
        "enabled": true,                                        -> Flag indicating if authentication is enabled
        "drop": false,                                          -> Flag indicating if users should be dropped during module startup
        "merge": true,                                          -> Flag indicating if users should be merged during module startup
        "users": [                                              -> Array of users to merge (insert new or update existing)
          {
            "username": "viewer",                               -> Unique username
            "password": "DAAF8173380C604B392A1EF8D7559AA0",     -> Hashed password if 'salt' is defined, otherwise plain text password
            "salt": "BA1170DE9ADE8D29D2C18FD789EAB3BD",         -> Salt used to hash password
            "roles": [ "VIEWER" ]                               -> Array of user roles (see Enumerations below)
          }
        ]
      },
      "ssl": {
        "enabled": true,                                        -> Flag indicating if HTTP server should run with enabled SSL/TLS
        "keystorePath": "/path/to/server-keystore.jks",         -> Absolute path to Java keystore file (JKS)
        "keystorePassword": "wibble"                            -> Password of Java keystore
      }
    },
    {
      "name": "sender02",
      ...
    }
  ]
}


On this page

Table of Contents