Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / benjamin-hodgson/asynqp issues and pull requests

#109 - Support for Python 3.8 and later

Issue - State: open - Opened by manojpandey almost 4 years ago - 1 comment

#108 - 0.5.1 broken under 3.7; Fix already merged - needs release

Issue - State: closed - Opened by pglombardo about 6 years ago - 2 comments

#107 - how do I check connection status before publish

Issue - State: open - Opened by hritik09 over 6 years ago - 1 comment

#105 - Increment version to 0.6.1

Pull Request - State: open - Opened by evmyzgin over 6 years ago - 2 comments

#104 - Add support for Python up to 3.7.

Pull Request - State: closed - Opened by evmyzgin over 6 years ago - 2 comments

#103 - Await is reserved keyword in python3.7

Issue - State: closed - Opened by Wolodija over 6 years ago - 2 comments

#100 - Guaranteed delivery of published messages

Issue - State: open - Opened by tkukushkin about 7 years ago - 1 comment

#99 - Split two different IndexErrors in Synchroniser.notify

Pull Request - State: closed - Opened by romantolkachyov about 7 years ago

#98 - fix asyncio.async deprecation warning (replaced with ensure_future)

Pull Request - State: closed - Opened by romantolkachyov over 7 years ago - 2 comments

#97 - Deprecation warning for asyncio.async()

Issue - State: closed - Opened by romantolkachyov over 7 years ago - 2 comments
Labels: help wanted

#96 - Please delete this isse...

Issue - State: closed - Opened by denisroldan over 7 years ago

#95 - Give ability to send non-ascii via using dict as message body

Issue - State: open - Opened by purpleP almost 8 years ago

#94 - Synchroniser.notify hits 'unexpected method notification' in tests.

Issue - State: open - Opened by alexjc almost 8 years ago - 1 comment

#93 - Doc mandatory param; cross link to set_return_handler

Pull Request - State: closed - Opened by bitdancer almost 8 years ago - 2 comments

#92 - Issue using partials in `Queue.consume()`

Issue - State: open - Opened by bstempi about 8 years ago - 2 comments

#91 - It's possible to lock up queue.consume() so that it never emits any callback.

Issue - State: open - Opened by CompPhy about 8 years ago - 1 comment

#90 - Provide support to send message directly to queue bypassing exchange

Issue - State: closed - Opened by horpto about 8 years ago - 1 comment

#89 - Queue get as a blocking method

Issue - State: closed - Opened by pkolchanov about 8 years ago - 2 comments

#88 - Add simple on_connection_close handler without exception handlers

Pull Request - State: closed - Opened by polosaty over 8 years ago - 3 comments

#87 - delivery mode not defaulted

Issue - State: open - Opened by dmacnet over 8 years ago

#86 - Mark amq.rabbitmq.reply-to as valid queue name

Pull Request - State: closed - Opened by cybergrind over 8 years ago - 2 comments

#85 - Why callback in consume can't be coroutine?

Issue - State: closed - Opened by purpleP over 8 years ago - 3 comments

#84 - How to consume from multiple queues concurrently

Issue - State: closed - Opened by farefernandez over 8 years ago - 3 comments

#83 - No enforcement of unidirectional channels

Issue - State: open - Opened by dmacnet over 8 years ago

#82 - Async iterable for consuming messages instead of callback

Issue - State: open - Opened by purpleP over 8 years ago

#81 - Changed all occurences of 'try except pass' into 'with suppress' context manager

Pull Request - State: closed - Opened by purpleP over 8 years ago - 2 comments

#80 - Please upload current version into PyPI.

Issue - State: closed - Opened by mosquito over 8 years ago - 1 comment

#79 - Unhandled socket.send() raised exception.

Issue - State: open - Opened by dmacnet almost 9 years ago - 1 comment
Labels: bug

#78 - Queue should not bind to default exchange

Pull Request - State: closed - Opened by txomon almost 9 years ago - 12 comments

#77 - Using default exchange

Issue - State: closed - Opened by txomon almost 9 years ago - 2 comments

#76 - Correctly handle zero-length messages

Pull Request - State: closed - Opened by anton-ryzhov almost 9 years ago - 8 comments

#75 - Changed the reconnect example to show new features in 0.5

Pull Request - State: closed - Opened by tvoinarovskyi almost 9 years ago - 1 comment

#74 - Added backward compatible closed future.

Pull Request - State: closed - Opened by tvoinarovskyi almost 9 years ago - 2 comments

#73 - Release 0.6 planned changes

Issue - State: open - Opened by tvoinarovskyi almost 9 years ago - 3 comments

#72 - Added v0.5 changes and fixed conformance doc page

Pull Request - State: closed - Opened by tvoinarovskyi almost 9 years ago - 2 comments

#71 - Refactor the return handler

Issue - State: open - Opened by tvoinarovskyi almost 9 years ago - 1 comment
Labels: enhancement

#70 - Remove QueuedReader and fix method cancellation

Pull Request - State: open - Opened by tvoinarovskyi almost 9 years ago - 2 comments

#69 - Fixed new W503 flake8 checks

Pull Request - State: closed - Opened by tvoinarovskyi almost 9 years ago - 1 comment

#68 - Implement setting immediate flag when publishing message

Issue - State: open - Opened by socketpair almost 9 years ago

#67 - Question: Is it better than aioamqp ?

Issue - State: closed - Opened by socketpair almost 9 years ago - 7 comments

#66 - Fixed amqp properties reading. Had invalid flag checks.

Pull Request - State: closed - Opened by tvoinarovskyi about 9 years ago - 6 comments

#65 - Added QueuedConsumer implementation

Pull Request - State: open - Opened by tvoinarovskyi about 9 years ago - 2 comments

#64 - Fix cancelling channel operations

Pull Request - State: closed - Opened by tvoinarovskyi about 9 years ago - 1 comment

#63 - Added nowait parameters to queue and exchange declarations

Pull Request - State: closed - Opened by tvoinarovskyi about 9 years ago - 1 comment

#61 - Passive declare of exchanges and queues

Pull Request - State: closed - Opened by tvoinarovskyi over 9 years ago - 2 comments

#60 - Added server side consumer cancel

Pull Request - State: closed - Opened by tvoinarovskyi over 9 years ago - 8 comments

#59 - Fix #57 Components not killed when rabbit just closes transport

Pull Request - State: closed - Opened by tvoinarovskyi over 9 years ago - 1 comment

#58 - If we close connection and try to open channel it deadlocks

Issue - State: closed - Opened by tvoinarovskyi over 9 years ago - 1 comment

#57 - Components not killed when rabbit just closes transport.

Issue - State: closed - Opened by TarasLevelUp over 9 years ago - 1 comment

#56 - Need for more FlowControl?

Issue - State: open - Opened by tvoinarovskyi over 9 years ago - 1 comment

#55 - Refactored close procedures to dispatch Errors for all components

Pull Request - State: closed - Opened by tvoinarovskyi over 9 years ago - 5 comments

#53 - Reader refactor

Pull Request - State: closed - Opened by tvoinarovskyi over 9 years ago - 1 comment

#52 - Coroutines crash when are cancelled

Issue - State: open - Opened by tvoinarovskyi over 9 years ago - 3 comments
Labels: bug

#51 - Added FlowControl to Protocol

Pull Request - State: open - Opened by TarasLevelUp over 9 years ago - 2 comments

#50 - Refactor message_receiver to not use async tasks on message consuming

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 2 comments

#49 - Refactored Synchroniser to use simpler self._futures construct

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 4 comments

#48 - Refactored reader to not use async calls

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 2 comments

#47 - Refactor internals. Fix finalizers.

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 4 comments

#46 - Fixed heartbeat

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 3 comments

#45 - Refactor HeartbeatMonitor

Issue - State: closed - Opened by TarasLevelUp over 9 years ago - 2 comments
Labels: bug

#44 - Refactor QueueReader to use single async task

Issue - State: closed - Opened by TarasLevelUp over 9 years ago - 4 comments

#43 - Added some tests on unset loop

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 2 comments

#42 - Added explicit loop passing to all components from connection.

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 1 comment

#41 - Fix #40 set TCP_NODELAY by default

Pull Request - State: closed - Opened by socketpair over 9 years ago - 5 comments

#40 - Not using TCP_NODELAY reduce performance considerably

Issue - State: closed - Opened by socketpair over 9 years ago - 6 comments
Labels: enhancement

#39 - IncomingMessage.reject documentation or API wrong

Issue - State: closed - Opened by socketpair over 9 years ago - 1 comment

#38 - Provide API to "wait until message arrive and get it"

Issue - State: closed - Opened by socketpair over 9 years ago - 1 comment
Labels: question, wontfix

#37 - AMQP protocol error while valid usage

Issue - State: closed - Opened by socketpair over 9 years ago - 7 comments

#36 - Fix connection close after graceful close from server

Pull Request - State: closed - Opened by TarasLevelUp over 9 years ago - 3 comments

#35 - Connection can not close after graceful server restart

Issue - State: closed - Opened by TarasLevelUp over 9 years ago - 1 comment
Labels: bug

#34 - Can't handle ConnectionLost when used as a Consumer

Issue - State: open - Opened by TarasLevelUp over 9 years ago - 36 comments
Labels: enhancement

#33 - Support passive declarations of queues and exchanges

Issue - State: closed - Opened by OscaTutenchamon over 9 years ago - 3 comments
Labels: enhancement

#32 - NotImplementedError when passing NoneType value to the buffer

Issue - State: closed - Opened by renatomassaro over 9 years ago - 4 comments
Labels: bug

#31 - connection_lost should not raise exception when called with None

Issue - State: closed - Opened by urbaniak over 9 years ago - 5 comments
Labels: bug

#30 - Documentation of new features and changes

Issue - State: closed - Opened by benjamin-hodgson over 9 years ago

#29 - Address divergences between Rabbit and AMQP spec

Issue - State: open - Opened by benjamin-hodgson over 9 years ago - 1 comment
Labels: bug

#28 - Table length should be unsigned long

Pull Request - State: closed - Opened by fwiesel over 9 years ago - 3 comments

#27 - Pass custom attribute tables

Pull Request - State: closed - Opened by fwiesel over 9 years ago - 4 comments

#26 - Improved RabbitMq Compatibility

Pull Request - State: closed - Opened by fwiesel over 9 years ago - 9 comments

#25 - Timestamp

Pull Request - State: closed - Opened by fwiesel over 9 years ago - 4 comments

#24 - Signed/unsigned serialization and expanded table serialization

Pull Request - State: closed - Opened by fwiesel over 9 years ago - 1 comment

#23 - Make sure all exceptions have sensible types and error messages

Issue - State: closed - Opened by benjamin-hodgson over 9 years ago - 1 comment
Labels: bug

#22 - No exception when failing to create a queue

Issue - State: closed - Opened by therve over 9 years ago - 3 comments
Labels: bug

#21 - Stop squashing OsError into ConnectionRefusedError when connecting

Pull Request - State: closed - Opened by lenzenmi over 9 years ago - 1 comment

#20 - Example/reconnecting socket

Pull Request - State: closed - Opened by lenzenmi over 9 years ago

#19 - Added new exceptions and logic to allow reconnecting connections

Pull Request - State: closed - Opened by lenzenmi over 9 years ago - 3 comments

#18 - Example/reconnecting socket

Pull Request - State: closed - Opened by lenzenmi over 9 years ago

#17 - Added new exceptions and logic for reconnecting broken connections.

Pull Request - State: closed - Opened by lenzenmi over 9 years ago

#16 - Make `transport` and `protocol` public attributes on `Connection`

Issue - State: closed - Opened by benjamin-hodgson over 9 years ago - 1 comment
Labels: enhancement

#15 - Raise exception on lost connection

Issue - State: closed - Opened by lenzenmi over 9 years ago - 9 comments
Labels: bug

#14 - do not pass host and port to loop.create_connection when there's a sock

Pull Request - State: closed - Opened by urbaniak over 9 years ago - 8 comments
Labels: enhancement

#13 - Update README.md according to #9

Pull Request - State: closed - Opened by renatomassaro almost 10 years ago - 1 comment

#12 - rabbitmq reports amqp error when trying to publish message

Issue - State: closed - Opened by georgwaechter almost 10 years ago - 13 comments
Labels: bug

#9 - "Task was destroyed but is pending!" error in tests

Issue - State: closed - Opened by benjamin-hodgson about 10 years ago - 3 comments
Labels: bug

#2 - Ability to pass attributes to declare_queue

Issue - State: closed - Opened by ralphje over 10 years ago - 3 comments
Labels: enhancement