Skip to content

Commit

Permalink
Fix after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
lordgamez committed Aug 14, 2024
1 parent 23eb836 commit 7a9383a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions extensions/standard-processors/modbus/FetchModbusTcp.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ namespace org::apache::nifi::minifi::modbus {

void FetchModbusTcp::onSchedule(core::ProcessContext& context, core::ProcessSessionFactory&) {
const auto record_set_writer_name = context.getProperty(RecordSetWriter);
record_set_writer_ = std::dynamic_pointer_cast<core::RecordSetWriter>(context.getControllerService(record_set_writer_name.value_or("")));
record_set_writer_ = std::dynamic_pointer_cast<core::RecordSetWriter>(context.getControllerService(record_set_writer_name.value_or(""), getUUID()));
if (!record_set_writer_) {
throw Exception{ExceptionType::PROCESS_SCHEDULE_EXCEPTION, "Invalid or missing RecordSetWriter"};
}
Expand Down Expand Up @@ -66,7 +66,7 @@ void FetchModbusTcp::onSchedule(core::ProcessContext& context, core::ProcessSess

ssl_context_.reset();
if (const auto controller_service_name = context.getProperty(SSLContextService); controller_service_name && !IsNullOrEmpty(*controller_service_name)) {
if (auto controller_service = context.getControllerService(*controller_service_name)) {
if (auto controller_service = context.getControllerService(*controller_service_name, getUUID())) {
if (const auto ssl_context_service = std::dynamic_pointer_cast<minifi::controllers::SSLContextService>(controller_service)) {
ssl_context_ = utils::net::getSslContext(*ssl_context_service);
} else {
Expand Down

0 comments on commit 7a9383a

Please sign in to comment.