@@ 11166-11224 (lines=59) @@ | ||
11163 | __repr__ = __str__ |
|
11164 | ||
11165 | ||
11166 | class ModifySubscriptionParameters(FrozenClass): |
|
11167 | ''' |
|
11168 | :ivar SubscriptionId: |
|
11169 | :vartype SubscriptionId: UInt32 |
|
11170 | :ivar RequestedPublishingInterval: |
|
11171 | :vartype RequestedPublishingInterval: Double |
|
11172 | :ivar RequestedLifetimeCount: |
|
11173 | :vartype RequestedLifetimeCount: UInt32 |
|
11174 | :ivar RequestedMaxKeepAliveCount: |
|
11175 | :vartype RequestedMaxKeepAliveCount: UInt32 |
|
11176 | :ivar MaxNotificationsPerPublish: |
|
11177 | :vartype MaxNotificationsPerPublish: UInt32 |
|
11178 | :ivar Priority: |
|
11179 | :vartype Priority: Byte |
|
11180 | ''' |
|
11181 | def __init__(self, binary=None): |
|
11182 | if binary is not None: |
|
11183 | self._binary_init(binary) |
|
11184 | self._freeze = True |
|
11185 | return |
|
11186 | self.SubscriptionId = 0 |
|
11187 | self.RequestedPublishingInterval = 0 |
|
11188 | self.RequestedLifetimeCount = 0 |
|
11189 | self.RequestedMaxKeepAliveCount = 0 |
|
11190 | self.MaxNotificationsPerPublish = 0 |
|
11191 | self.Priority = 0 |
|
11192 | self._freeze = True |
|
11193 | ||
11194 | def to_binary(self): |
|
11195 | packet = [] |
|
11196 | packet.append(uatype_UInt32.pack(self.SubscriptionId)) |
|
11197 | packet.append(uatype_Double.pack(self.RequestedPublishingInterval)) |
|
11198 | packet.append(uatype_UInt32.pack(self.RequestedLifetimeCount)) |
|
11199 | packet.append(uatype_UInt32.pack(self.RequestedMaxKeepAliveCount)) |
|
11200 | packet.append(uatype_UInt32.pack(self.MaxNotificationsPerPublish)) |
|
11201 | packet.append(uatype_Byte.pack(self.Priority)) |
|
11202 | return b''.join(packet) |
|
11203 | ||
11204 | @staticmethod |
|
11205 | def from_binary(data): |
|
11206 | return ModifySubscriptionParameters(data) |
|
11207 | ||
11208 | def _binary_init(self, data): |
|
11209 | self.SubscriptionId = uatype_UInt32.unpack(data.read(4))[0] |
|
11210 | self.RequestedPublishingInterval = uatype_Double.unpack(data.read(8))[0] |
|
11211 | self.RequestedLifetimeCount = uatype_UInt32.unpack(data.read(4))[0] |
|
11212 | self.RequestedMaxKeepAliveCount = uatype_UInt32.unpack(data.read(4))[0] |
|
11213 | self.MaxNotificationsPerPublish = uatype_UInt32.unpack(data.read(4))[0] |
|
11214 | self.Priority = uatype_Byte.unpack(data.read(1))[0] |
|
11215 | ||
11216 | def __str__(self): |
|
11217 | return 'ModifySubscriptionParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
11218 | 'RequestedPublishingInterval:' + str(self.RequestedPublishingInterval) + ', ' + \ |
|
11219 | 'RequestedLifetimeCount:' + str(self.RequestedLifetimeCount) + ', ' + \ |
|
11220 | 'RequestedMaxKeepAliveCount:' + str(self.RequestedMaxKeepAliveCount) + ', ' + \ |
|
11221 | 'MaxNotificationsPerPublish:' + str(self.MaxNotificationsPerPublish) + ', ' + \ |
|
11222 | 'Priority:' + str(self.Priority) + ')' |
|
11223 | ||
11224 | __repr__ = __str__ |
|
11225 | ||
11226 | ||
11227 | class ModifySubscriptionRequest(FrozenClass): |
|
@@ 10970-11028 (lines=59) @@ | ||
10967 | __repr__ = __str__ |
|
10968 | ||
10969 | ||
10970 | class CreateSubscriptionParameters(FrozenClass): |
|
10971 | ''' |
|
10972 | :ivar RequestedPublishingInterval: |
|
10973 | :vartype RequestedPublishingInterval: Double |
|
10974 | :ivar RequestedLifetimeCount: |
|
10975 | :vartype RequestedLifetimeCount: UInt32 |
|
10976 | :ivar RequestedMaxKeepAliveCount: |
|
10977 | :vartype RequestedMaxKeepAliveCount: UInt32 |
|
10978 | :ivar MaxNotificationsPerPublish: |
|
10979 | :vartype MaxNotificationsPerPublish: UInt32 |
|
10980 | :ivar PublishingEnabled: |
|
10981 | :vartype PublishingEnabled: Boolean |
|
10982 | :ivar Priority: |
|
10983 | :vartype Priority: Byte |
|
10984 | ''' |
|
10985 | def __init__(self, binary=None): |
|
10986 | if binary is not None: |
|
10987 | self._binary_init(binary) |
|
10988 | self._freeze = True |
|
10989 | return |
|
10990 | self.RequestedPublishingInterval = 0 |
|
10991 | self.RequestedLifetimeCount = 0 |
|
10992 | self.RequestedMaxKeepAliveCount = 0 |
|
10993 | self.MaxNotificationsPerPublish = 0 |
|
10994 | self.PublishingEnabled = True |
|
10995 | self.Priority = 0 |
|
10996 | self._freeze = True |
|
10997 | ||
10998 | def to_binary(self): |
|
10999 | packet = [] |
|
11000 | packet.append(uatype_Double.pack(self.RequestedPublishingInterval)) |
|
11001 | packet.append(uatype_UInt32.pack(self.RequestedLifetimeCount)) |
|
11002 | packet.append(uatype_UInt32.pack(self.RequestedMaxKeepAliveCount)) |
|
11003 | packet.append(uatype_UInt32.pack(self.MaxNotificationsPerPublish)) |
|
11004 | packet.append(uatype_Boolean.pack(self.PublishingEnabled)) |
|
11005 | packet.append(uatype_Byte.pack(self.Priority)) |
|
11006 | return b''.join(packet) |
|
11007 | ||
11008 | @staticmethod |
|
11009 | def from_binary(data): |
|
11010 | return CreateSubscriptionParameters(data) |
|
11011 | ||
11012 | def _binary_init(self, data): |
|
11013 | self.RequestedPublishingInterval = uatype_Double.unpack(data.read(8))[0] |
|
11014 | self.RequestedLifetimeCount = uatype_UInt32.unpack(data.read(4))[0] |
|
11015 | self.RequestedMaxKeepAliveCount = uatype_UInt32.unpack(data.read(4))[0] |
|
11016 | self.MaxNotificationsPerPublish = uatype_UInt32.unpack(data.read(4))[0] |
|
11017 | self.PublishingEnabled = uatype_Boolean.unpack(data.read(1))[0] |
|
11018 | self.Priority = uatype_Byte.unpack(data.read(1))[0] |
|
11019 | ||
11020 | def __str__(self): |
|
11021 | return 'CreateSubscriptionParameters(' + 'RequestedPublishingInterval:' + str(self.RequestedPublishingInterval) + ', ' + \ |
|
11022 | 'RequestedLifetimeCount:' + str(self.RequestedLifetimeCount) + ', ' + \ |
|
11023 | 'RequestedMaxKeepAliveCount:' + str(self.RequestedMaxKeepAliveCount) + ', ' + \ |
|
11024 | 'MaxNotificationsPerPublish:' + str(self.MaxNotificationsPerPublish) + ', ' + \ |
|
11025 | 'PublishingEnabled:' + str(self.PublishingEnabled) + ', ' + \ |
|
11026 | 'Priority:' + str(self.Priority) + ')' |
|
11027 | ||
11028 | __repr__ = __str__ |
|
11029 | ||
11030 | ||
11031 | class CreateSubscriptionRequest(FrozenClass): |