Merge pull request #60 from gmr/functional-consumer

4.0: Codec class, consolidated models, BaseConsumer + TransactionConsumer

Author: gmr

.codeclimate.yml

@@ -27,18 +27,24 @@ jobs:
 
       - name: Install dependencies
         run: uv sync --all-groups
+        env:
+          UV_CONFIG_FILE: /dev/null
 
       - name: Create build directory
         run: mkdir -p build
 
       - name: Lint Check
         run: uv run pre-commit run --all-files
+        env:
+          UV_CONFIG_FILE: /dev/null
 
       - name: Run tests
         run: |
           uv run coverage run
           uv run coverage report
           uv run coverage xml
+        env:
+          UV_CONFIG_FILE: /dev/null
 
       - name: Upload Coverage
         uses: codecov/codecov-action@v5

.github/workflows/testing.yaml

@@ -1,4 +1,4 @@
-Copyright (c) 2009-2017, Gavin M. Roy
+Copyright (c) 2009-2026, Gavin M. Roy
 All rights reserved.
 
 Redistribution and use in source and binary forms, with or without modification,

.travis.yml

@@ -10,7 +10,6 @@ each run in an isolated process. It has the ability to collect statistical
 data from the consumer processes and report on it.
 
 [![Version](https://img.shields.io/pypi/v/rejected.svg?)](https://pypi.python.org/pypi/rejected)
-[![Coverage](https://img.shields.io/codecov/c/github/gmr/rejected.svg?)](https://codecov.io/github/gmr/rejected?branch=main)
 [![License](https://img.shields.io/pypi/l/rejected.svg?)](https://github.com/gmr/rejected/blob/main/LICENSE)
 
 ## Features
@@ -30,6 +29,7 @@ pip install rejected
 For optional features:
 
 ```bash
+pip install rejected[avro]     # Avro support
 pip install rejected[html]     # HTML message body support
 pip install rejected[msgpack]  # MessagePack support
 ```
@@ -49,37 +49,6 @@ LOGGER = logging.getLogger(__name__)
 
 class Test(consumer.Consumer):
 
-    def process(self, message):
-        LOGGER.debug('In Test.process: %s', message.body)
+    async def process(self) -> None:
+        LOGGER.debug('In Test.process: %s', self.body)
 ```
-
-## Async Consumer
-
-To make a consumer async, you can use Tornado's `@gen.coroutine` decorator on the
-`Consumer.prepare` and `Consumer.process` methods. Asynchronous consumers allow
-you to use async clients like Tornado's `AsyncHTTPClient` to perform parallel
-tasks when processing a single message.
-
-```python
-import logging
-
-from rejected import consumer
-
-from tornado import gen
-from tornado import httpclient
-
-
-class AsyncExampleConsumer(consumer.Consumer):
-
-    @gen.coroutine
-    def process(self):
-        LOGGER.debug('Message: %r', self.body)
-        http_client = httpclient.AsyncHTTPClient()
-        results = yield [http_client.fetch('http://www.github.com'),
-                         http_client.fetch('http://www.reddit.com')]
-        LOGGER.info('Length: %r', [len(r.body) for r in results])
-```
-
-## Version History
-
-See [HISTORY.md](HISTORY.md) or the [documentation](https://rejected.readthedocs.io).