diff --git a/kmip/core/messages/contents.py b/kmip/core/messages/contents.py index 2912dbe..470c431 100644 --- a/kmip/core/messages/contents.py +++ b/kmip/core/messages/contents.py @@ -506,6 +506,13 @@ class MessageExtension(Struct): super(MessageExtension, self).__init__(enums.Tags.MESSAGE_EXTENSION) +# 6.19 +class ServerCorrelationValue(TextString): + def __init__(self, value=None): + super(ServerCorrelationValue, self).__init__( + value, enums.Tags.SERVER_CORRELATION_VALUE) + + # 9.1.3.2.2 class KeyCompressionType(Enumeration): diff --git a/kmip/core/messages/messages.py b/kmip/core/messages/messages.py index e2e37cf..c1b4c6b 100644 --- a/kmip/core/messages/messages.py +++ b/kmip/core/messages/messages.py @@ -150,12 +150,14 @@ class ResponseHeader(Struct): protocol_version=None, time_stamp=None, batch_count=None, - server_hashed_password=None): + server_hashed_password=None, + server_correlation_value=None): super(ResponseHeader, self).__init__(tag=Tags.RESPONSE_HEADER) self.protocol_version = protocol_version self.time_stamp = time_stamp self.batch_count = batch_count self.server_hashed_password = server_hashed_password + self.server_correlation_value = server_correlation_value self.validate() @@ -204,6 +206,10 @@ class ResponseHeader(Struct): server_hashed_password.read(tstream, kmip_version=kmip_version) self._server_hashed_password = server_hashed_password + if self.is_tag_next(enums.Tags.SERVER_CORRELATION_VALUE, tstream): + self.server_correlation_value = contents.ServerCorrelationValue() + self.server_correlation_value.read(tstream, kmip_version=kmip_version) + self.batch_count = contents.BatchCount() self.batch_count.read(tstream, kmip_version=kmip_version)