Neodym is a thin message-bus wrapper around asyncore. It includes a client and a server dispatcher, as well as an easily configurable message-bus. Json serves as the designated transport syntax.
This is a simple server:
import neodym
import logging
neodym.log_level = logging.DEBUG
baseConfig = neodym.baseConfig()
logging.basicConfig(**baseConfig)
neodym.register('echo', ['cargo'])
neodym.init()
server = neodym.Server(('127.0.0.1', 42742))
server.server_activate()
class EchoHandler(neodym.handler.Handler):
def handle(self, message, connection):
cargo = message.get_attr('cargo')
message.set_attr('cargo', str(cargo).upper())
connection.put(message)
echo_handler = EchoHandler('echo')
server.serve_forever()
This is a simple client:
import neodym
import logging
import time
neodym.log_level = logging.DEBUG
baseConfig = neodym.baseConfig()
logging.basicConfig(**baseConfig)
neodym.register('echo', ['cargo'])
neodym.init()
client = neodym.Client('127.0.0.1', 42742)
client.client_connect()
connection = client.connection()
message = neodym.message.Message('echo', ['foobar'])
connection.put(message)
client.update()
time.sleep(0.1)
client.update()
Neodym - A thin message-bus layer around asyncore. Copyright (C) 2013 Brian Wiborg [email protected]
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see http://www.gnu.org/licenses/.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent