| 204 | } |
| 205 | |
| 206 | void ProcessSession::transfer(const std::shared_ptr<core::FlowFile> &flow, Relationship relationship) { |
| 207 | logging::LOG_INFO(logger_) << "Transferring " << flow->getUUIDStr() << " from " << process_context_->getProcessorNode()->getName() << " to relationship " << relationship.getName(); |
| 208 | utils::Identifier uuid = flow->getUUID(); |
| 209 | _transferRelationship[uuid] = relationship; |
| 210 | flow->setDeleted(false); |
| 211 | } |
| 212 | |
| 213 | void ProcessSession::write(const std::shared_ptr<core::FlowFile> &flow, OutputStreamCallback *callback) { |
| 214 | std::shared_ptr<ResourceClaim> claim = content_session_->create(); |