1 # -*- coding: utf-8 -*-
3 # Copyright 2018 Telefonica S.A.
5 # Licensed under the Apache License, Version 2.0 (the "License");
6 # you may not use this file except in compliance with the License.
7 # You may obtain a copy of the License at
9 # http://www.apache.org/licenses/LICENSE-2.0
11 # Unless required by applicable law or agreed to in writing, software
12 # distributed under the License is distributed on an "AS IS" BASIS,
13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
15 # See the License for the specific language governing permissions and
16 # limitations under the License.
18 from http
import HTTPStatus
20 __author__
= "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
23 class MsgException(Exception):
25 Base Exception class for all msgXXXX exceptions
28 def __init__(self
, message
, http_code
=HTTPStatus
.SERVICE_UNAVAILABLE
):
31 :param message: descriptive text
32 :param http_code: <http.HTTPStatus> type. It contains ".value" (http error code) and ".name" (http error name
34 self
.http_code
= http_code
35 Exception.__init
__(self
, "messaging exception " + message
)
38 class MsgBase(object):
40 Base class for all msgXXXX classes
46 def connect(self
, config
):
52 def write(self
, topic
, key
, msg
):
53 raise MsgException("Method 'write' not implemented", http_code
=HTTPStatus
.INTERNAL_SERVER_ERROR
)
55 def read(self
, topic
):
56 raise MsgException("Method 'read' not implemented", http_code
=HTTPStatus
.INTERNAL_SERVER_ERROR
)
58 async def aiowrite(self
, topic
, key
, msg
, loop
=None):
59 raise MsgException("Method 'aiowrite' not implemented", http_code
=HTTPStatus
.INTERNAL_SERVER_ERROR
)
61 async def aioread(self
, topic
, loop
=None, callback
=None, aiocallback
=None, **kwargs
):
62 raise MsgException("Method 'aioread' not implemented", http_code
=HTTPStatus
.INTERNAL_SERVER_ERROR
)