| @@ 11854-11888 (lines=35) @@ | ||
| 11851 | __repr__ = __str__ |
|
| 11852 | ||
| 11853 | ||
| 11854 | class SubscriptionAcknowledgement(FrozenClass): |
|
| 11855 | ''' |
|
| 11856 | :ivar SubscriptionId: |
|
| 11857 | :vartype SubscriptionId: UInt32 |
|
| 11858 | :ivar SequenceNumber: |
|
| 11859 | :vartype SequenceNumber: UInt32 |
|
| 11860 | ''' |
|
| 11861 | def __init__(self, binary=None): |
|
| 11862 | if binary is not None: |
|
| 11863 | self._binary_init(binary) |
|
| 11864 | self._freeze = True |
|
| 11865 | return |
|
| 11866 | self.SubscriptionId = 0 |
|
| 11867 | self.SequenceNumber = 0 |
|
| 11868 | self._freeze = True |
|
| 11869 | ||
| 11870 | def to_binary(self): |
|
| 11871 | packet = [] |
|
| 11872 | packet.append(uatype_UInt32.pack(self.SubscriptionId)) |
|
| 11873 | packet.append(uatype_UInt32.pack(self.SequenceNumber)) |
|
| 11874 | return b''.join(packet) |
|
| 11875 | ||
| 11876 | @staticmethod |
|
| 11877 | def from_binary(data): |
|
| 11878 | return SubscriptionAcknowledgement(data) |
|
| 11879 | ||
| 11880 | def _binary_init(self, data): |
|
| 11881 | self.SubscriptionId = uatype_UInt32.unpack(data.read(4))[0] |
|
| 11882 | self.SequenceNumber = uatype_UInt32.unpack(data.read(4))[0] |
|
| 11883 | ||
| 11884 | def __str__(self): |
|
| 11885 | return 'SubscriptionAcknowledgement(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
| 11886 | 'SequenceNumber:' + str(self.SequenceNumber) + ')' |
|
| 11887 | ||
| 11888 | __repr__ = __str__ |
|
| 11889 | ||
| 11890 | ||
| 11891 | class PublishParameters(FrozenClass): |
|
| @@ 214-240 (lines=27) @@ | ||
| 211 | __repr__ = __str__ |
|
| 212 | ||
| 213 | ||
| 214 | class SequenceHeader(uatypes.FrozenClass): |
|
| 215 | ||
| 216 | def __init__(self): |
|
| 217 | self.SequenceNumber = None |
|
| 218 | self.RequestId = None |
|
| 219 | self._freeze = True |
|
| 220 | ||
| 221 | @staticmethod |
|
| 222 | def from_binary(data): |
|
| 223 | obj = SequenceHeader() |
|
| 224 | obj.SequenceNumber = uatype_UInt32.unpack(data.read(4))[0] |
|
| 225 | obj.RequestId = uatype_UInt32.unpack(data.read(4))[0] |
|
| 226 | return obj |
|
| 227 | ||
| 228 | def to_binary(self): |
|
| 229 | b = [] |
|
| 230 | b.append(uatype_UInt32.pack(self.SequenceNumber)) |
|
| 231 | b.append(uatype_UInt32.pack(self.RequestId)) |
|
| 232 | return b"".join(b) |
|
| 233 | ||
| 234 | @staticmethod |
|
| 235 | def max_size(): |
|
| 236 | return struct.calcsize("<II") |
|
| 237 | ||
| 238 | def __str__(self): |
|
| 239 | return "{}(SequenceNumber:{}, RequestId:{} )".format(self.__class__.__name__, self.SequenceNumber, self.RequestId) |
|
| 240 | __repr__ = __str__ |
|
| 241 | ||
| 242 | ||
| 243 | class CryptographyNone: |
|