1 package org.bitrepository.protocol.messagebus.logger;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25 import org.bitrepository.bitrepositorymessages.GetChecksumsFinalResponse;
26 import org.bitrepository.bitrepositorymessages.GetChecksumsRequest;
27 import org.bitrepository.bitrepositorymessages.IdentifyPillarsForGetChecksumsRequest;
28 import org.bitrepository.bitrepositorymessages.Message;
29 import org.bitrepository.common.utils.FileIDsUtils;
30
31
32
33
34 public class GetChecksumsMessageLogger extends DefaultMessagingLogger {
35 @Override
36 protected StringBuilder appendCustomInfo(StringBuilder messageSB, Message message) {
37 if (message instanceof IdentifyPillarsForGetChecksumsRequest) {
38 IdentifyPillarsForGetChecksumsRequest request = (IdentifyPillarsForGetChecksumsRequest) message;
39 messageSB.append(" FileIDs=" + FileIDsUtils.asString(request.getFileIDs()));
40 }
41
42 else if (message instanceof GetChecksumsRequest) {
43 GetChecksumsRequest request = (GetChecksumsRequest) message;
44 messageSB.append(" FileIDs=" + FileIDsUtils.asString(request.getFileIDs()));
45 if (request.getChecksumRequestForExistingFile() != null) {
46 messageSB.append(", ChecksumRequestForExistingFile=" + request.getChecksumRequestForExistingFile());
47 }
48 if (request.getResultAddress() != null) {
49 messageSB.append(", FileAddress=" + request.getResultAddress());
50 }
51 if (request.getMaxNumberOfResults() != null) {
52 messageSB.append(", MaxNumberOfResults=" + request.getMaxNumberOfResults());
53 }
54 if (request.getMaxTimestamp() != null) {
55 messageSB.append(", MaxTimestamp=" + request.getMaxTimestamp());
56 }
57 if (request.getMinTimestamp() != null) {
58 messageSB.append(", MinTimestamp=" + request.getMinTimestamp());
59 }
60 if (request.getAuditTrailInformation() != null) {
61 messageSB.append(", AuditTrailInformation=" + request.getAuditTrailInformation());
62 }
63 }
64
65 else if (message instanceof GetChecksumsFinalResponse) {
66 GetChecksumsFinalResponse response = (GetChecksumsFinalResponse) message;
67
68 if (response.getResultingChecksums() != null && response.getResultingChecksums().getChecksumDataItems() != null) {
69 messageSB.append(", NumberOfChecksums=" +
70 response.getResultingChecksums().getChecksumDataItems().size());
71 }
72
73 if (response.getChecksumRequestForExistingFile() != null) {
74 messageSB.append(", ChecksumRequestForExistingFile=" + response.getChecksumRequestForExistingFile());
75 }
76
77 if (response.isPartialResult() != null) {
78 messageSB.append(", PartialResult=" + response.isPartialResult());
79 }
80 }
81 return messageSB;
82 }
83 }