| 99 | return 0; |
| 100 | } |
| 101 | void GetTCP::initialize() { |
| 102 | // Set the supported properties |
| 103 | std::set<core::Property> properties; |
| 104 | properties.insert(EndpointList); |
| 105 | properties.insert(ConcurrentHandlers); |
| 106 | properties.insert(ConnectionAttemptLimit); |
| 107 | properties.insert(EndOfMessageByte); |
| 108 | properties.insert(ReconnectInterval); |
| 109 | properties.insert(ReceiveBufferSize); |
| 110 | properties.insert(StayConnected); |
| 111 | properties.insert(SSLContextService); |
| 112 | setSupportedProperties(properties); |
| 113 | // Set the supported relationships |
| 114 | std::set<core::Relationship> relationships; |
| 115 | relationships.insert(Success); |
| 116 | relationships.insert(Partial); |
| 117 | setSupportedRelationships(relationships); |
| 118 | } |
| 119 | |
| 120 | void GetTCP::onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) { |
| 121 | std::string value; |