aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorStanislav Marszalek <s.marszalek2@partner.samsung.com>2021-07-19 07:57:08 +0200
committerStanislav Marszalek <s.marszalek2@partner.samsung.com>2021-07-28 12:24:54 +0000
commitc7bc54b6e81532ad906de88f5ad7ed63259ff586 (patch)
treebbd9fdff15fb29176685b6a18161c58b0ae13318 /src/main/java
parent9a735bbccf18e984a9ae7c6bb81ee133ad911941 (diff)
O1 PM Bulk support - Unit test - I
Issue-ID: INT-1945 Signed-off-by: Stanislav Marszalek <s.marszalek2@partner.samsung.com> Change-Id: I02d3684c98d563d7f386de2fdf032e930ac41b2f
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/org/onap/a1pesimulator/data/ves/CommonEventHeader.java2
-rw-r--r--src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java4
2 files changed, 4 insertions, 2 deletions
diff --git a/src/main/java/org/onap/a1pesimulator/data/ves/CommonEventHeader.java b/src/main/java/org/onap/a1pesimulator/data/ves/CommonEventHeader.java
index baa8ab5..619f5ae 100644
--- a/src/main/java/org/onap/a1pesimulator/data/ves/CommonEventHeader.java
+++ b/src/main/java/org/onap/a1pesimulator/data/ves/CommonEventHeader.java
@@ -56,6 +56,8 @@ public class CommonEventHeader {
private String reportingEntityId;
+ private String nfVendorName;
+
private String nfcNamingCode;
private String nfNamingCode;
diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java b/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java
index d71cdf0..a4145d5 100644
--- a/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java
+++ b/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java
@@ -142,7 +142,7 @@ public class FtpServerService {
*
* @return SSHClient
*/
- private SSHClient getSSHClient() {
+ protected SSHClient getSSHClient() {
SSHClient client = new SSHClient();
try {
client.addHostKeyVerifier(new PromiscuousVerifier());
@@ -191,7 +191,7 @@ public class FtpServerService {
* @param fileData data about files which needs to be deleted
* @return empty Mono object
*/
- private Mono<FileData> resumeError(Throwable throwable, FileData fileData) {
+ protected Mono<FileData> resumeError(Throwable throwable, FileData fileData) {
log.error("Error occurs while uploading file to FTP server", throwable);
deletePMBulkFile(fileData.getPmBulkFile());
deletePMBulkFile(fileData.getArchivedPmBulkFile());