Skip to content

Commit

Permalink
MINIFICPP-2131 Refactored GetTCP
Browse files Browse the repository at this point in the history 
Signed-off-by: Ferenc Gerlits <[email protected]>
This closes #1592
  • Loading branch information
@martinzink @fgerlits
martinzink authored and fgerlits committed Jul 11, 2023
1 parent 4356e90 commit 68ba80a
Show file tree
Hide file tree
Showing 25 changed files with 833 additions and 775 deletions.
29 changes: 17 additions & 12 deletions PROCESSORS.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1136,16 +1136,16 @@ Establishes a TCP Server that defines and retrieves one or more byte messages fr

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

| Name | Default Value | Allowable Values | Description |
|----------------------------|---------------|------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| **endpoint-list** | | | A comma delimited list of the endpoints to connect to. The format should be <server_address>:<port>. |
| concurrent-handler-count | 1 | | Number of concurrent handlers for this session |
| reconnect-interval | 5 s | | The number of seconds to wait before attempting to reconnect to the endpoint. |
| Stay Connected | true | | Determines if we keep the same socket despite having no data |
| receive-buffer-size | 16 MB | | The size of the buffer to receive data in. Default 16384 (16MB). |
| SSL Context Service | | | SSL Context Service Name |
| connection-attempt-timeout | 3 | | Maximum number of connection attempts before attempting backup hosts, if configured |
| end-of-message-byte | 13 | | Byte value which denotes end of message. Must be specified as integer within the valid byte range (-128 thru 127). For example, '13' = Carriage return and '10' = New line. Default '13'. |
| Name | Default Value | Allowable Values | Description |
|-------------------------------|---------------|------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| **Endpoint List** | | | A comma delimited list of the endpoints to connect to. The format should be <server_address>:<port>. |
| SSL Context Service | | | SSL Context Service Name |
| Message Delimiter | \n | | Character that denotes the end of the message. |
| **Max Size of Message Queue** | 10000 | | Maximum number of messages allowed to be buffered before processing them when the processor is triggered. If the buffer is full, the message is ignored. If set to zero the buffer is unlimited. |
| Maximum Message Size | | | Optional size of the buffer to receive data in. |
| **Max Batch Size** | 500 | | The maximum number of messages to process at a time. |
| **Timeout** | 1s | | The timeout for connecting to and communicating with the destination.<br/>**Supports Expression Language: true** |
| **Reconnection Interval** | 1 min | | The duration to wait before attempting to reconnect to the endpoints.<br/>**Supports Expression Language: true** |

### Relationships

Expand All @@ -1154,6 +1154,13 @@ In the list below, the names of required properties appear in bold. Any other pr
| success | All files are routed to success |
| partial | Indicates an incomplete message as a result of encountering the end of message byte trigger |

### Output Attributes

| Attribute | Relationship | Description |
|-----------------|------------------|----------------------------------------------------------|
| source.endpoint | success, partial | The address of the source endpoint the message came from |



## GetUSBCamera

Expand Down Expand Up @@ -2779,5 +2786,3 @@ In the list below, the names of required properties appear in bold. Any other pr
|---------|-----------------------------------------|
| success | All files are routed to success |
| failure | Failed files are transferred to failure |


Loading

0 comments on commit 68ba80a

Please sign in to comment.