| 119 | } |
| 120 | |
| 121 | void RemoteProcessorGroupPort::initialize() { |
| 122 | // Set the supported properties |
| 123 | std::set<core::Property> properties; |
| 124 | properties.insert(hostName); |
| 125 | properties.insert(port); |
| 126 | properties.insert(SSLContext); |
| 127 | properties.insert(portUUID); |
| 128 | properties.insert(idleTimeout); |
| 129 | setSupportedProperties(properties); |
| 130 | // Set the supported relationships |
| 131 | std::set<core::Relationship> relationships; |
| 132 | relationships.insert(relation); |
| 133 | setSupportedRelationships(relationships); |
| 134 | |
| 135 | logger_->log_trace("Finished initialization"); |
| 136 | } |
| 137 | |
| 138 | void RemoteProcessorGroupPort::onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory>& /*sessionFactory*/) { |
| 139 | std::string value; |
no test coverage detected