qpid.messaging.exceptions

+ 1 # + 2 # Licensed to the Apache Software Foundation (ASF) under one + 3 # or more contributor license agreements. See the NOTICE file + 4 # distributed with this work for additional information + 5 # regarding copyright ownership. The ASF licenses this file + 6 # to you under the Apache License, Version 2.0 (the + 7 # "License"); you may not use this file except in compliance + 8 # with the License. You may obtain a copy of the License at + 9 # + 10 # http://www.apache.org/licenses/LICENSE-2.0 + 11 # + 12 # Unless required by applicable law or agreed to in writing, + 13 # software distributed under the License is distributed on an + 14 # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + 15 # KIND, either express or implied. See the License for the + 16 # specific language governing permissions and limitations + 17 # under the License. + 18 # + 19 +

20 -class Timeout(Exception): +

21 pass +

22 + 23 ## Messaging Errors + 24 +

25 -class MessagingError(Exception): +

26 +

27 - def __init__(self, code=None, text=None, **info): +

28 self.code = code + 29 self.text = text + 30 self.info = info + 31 if self.code is None: + 32 msg = self.text + 33 else: + 34 msg = "%s(%s)" % (self.text, self.code) + 35 if info: + 36 msg += " " + ", ".join(["%s=%r" % (k, v) for k, v in self.info.items()]) + 37 Exception.__init__(self, msg) +

38 -class InternalError(MessagingError): +

39 pass +

40 + 41 ## Connection Errors + 42 +

43 -class ConnectionError(MessagingError): +

44 """ + 45 The base class for all connection related exceptions. + 46 """ + 47 pass +

48 +

49 -class ConnectError(ConnectionError): +

50 """ + 51 Exception raised when there is an error connecting to the remote + 52 peer. + 53 """ + 54 pass +

55 +

56 -class VersionError(ConnectError): +

57 pass +

58 +

59 -class AuthenticationFailure(ConnectError): +

60 pass +

61 +

62 -class ConnectionClosed(ConnectionError): +

63 pass +

64 +

65 -class HeartbeatTimeout(ConnectionError): +

66 pass +

67 + 68 ## Session Errors + 69 +

70 -class SessionError(MessagingError): +

71 pass +

72 +

73 -class Detached(SessionError): +

74 """ + 75 Exception raised when an operation is attempted that is illegal when + 76 detached. + 77 """ + 78 pass +

79 +

80 -class NontransactionalSession(SessionError): +

81 """ + 82 Exception raised when commit or rollback is attempted on a non + 83 transactional session. + 84 """ + 85 pass +

86 +

87 -class TransactionError(SessionError): +

88 """Base class for transactional errors""" + 89 pass +

90 +

91 -class TransactionAborted(TransactionError): +

92 """The transaction was automatically rolled back. This could be due to an error + 93 on the broker, such as a store failure, or a connection failure during the + 94 transaction""" + 95 pass +

96 +

97 -class TransactionUnknown(TransactionError): +

98 """ The outcome of the transaction on the broker (commit or roll-back) is not + 99 known. This occurs when the connection fails after we sent the commit but +100 before we received a response.""" +101 pass +

102 +

103 -class UnauthorizedAccess(SessionError): +

104 pass +

105 +

106 -class ServerError(SessionError): +

107 pass +

108 +

109 -class SessionClosed(SessionError): +

110 pass +

111 +112 ## Link Errors +113 +

114 -class LinkError(MessagingError): +

115 pass +

116 +

117 -class InsufficientCapacity(LinkError): +

118 pass +

119 +

120 -class AddressError(LinkError): +

121 pass +

122 +

123 -class MalformedAddress(AddressError): +

124 pass +

125 +

126 -class InvalidOption(AddressError): +

127 pass +

128 +

129 -class ResolutionError(AddressError): +

130 pass +

131 +

132 -class AssertionFailed(ResolutionError): +

133 pass +

134 +

135 -class NotFound(ResolutionError): +

136 pass +

137 +

138 -class LinkClosed(LinkError): +

139 pass +

140 +141 ## Sender Errors +142 +

143 -class SenderError(LinkError): +

144 pass +

145 +

146 -class SendError(SenderError): +

147 pass +

148 +

149 -class TargetCapacityExceeded(SendError): +

150 pass +

151 +152 ## Receiver Errors +153 +

154 -class ReceiverError(LinkError): +

155 pass +

156 +

157 -class FetchError(ReceiverError): +

158 pass +

159 +

160 -class Empty(FetchError): +

161 """ +162 Exception raised by L{Receiver.fetch} when there is no message +163 available within the alloted time. +164 """ +165 pass +

166 +167 ## Message Content errors +

168 -class ContentError(MessagingError): +

169 """ +170 This type of exception will be returned to the application +171 once, and will not block further requests +172 """ +173 pass +

174 +

175 -class EncodeError(ContentError): +

176 pass +

177 +

178 -class DecodeError(ContentError): +

179 pass +

180 +

Source Code for Module qpid.messaging.exceptions