AMQP does not close channels
I use the following to send messages to client:
@defer.
def amqpSend(self, userAmqpKey, name_method, user_res):
send_func = getattr(
@defer.
def prepareClient(self, client):
channel = yield client.channel(1)
yield channel.
yield channel.
@defer.
def CreateThriftCli
I expect the channels to be closed but they are open.
# rabbitmqctl list_channels
<email address hidden> guest false 0 0
<email address hidden> guest false 1 0
<email address hidden> guest false 1118 0
It leads to channels locking.
# rabbitmqctl list_connections
guest 127.0.0.1 48892 locked
guest 127.0.0.1 48875 locked
guest 127.0.0.1 48866 locked
Is it a bug. If so how can I make it to work correctly?
Question information
- Language:
- English Edit question
- Status:
- Solved
- For:
- txAMQP Edit question
- Assignee:
- No assignee Edit question
- Solved by:
- DarkAnthey
- Solved:
- Last query:
- Last reply: