Connection.close() Issue

[Xiankang Zeng]

I use the codes to send json message:

def json_send(self): # json_message
       credentials = pika.PlainCredentials(self.user_name, self.password)
       connection = pika.BlockingConnection(
       pika.ConnectionParameters(host=self.host_ip, port=5672, credentials=credentials))
       channel = connection.channel()
       channel.exchange_declare(exchange=self.exchange, durable=True, auto_delete=True)
       channel.queue_declare(queue=self.queue, durable=True)
       message = json.dumps(self.json_message)
       channel.basic_publish(exchange=self.exchange, routing_key=self.routing_key,                         body=message, properties=pika.BasicProperties(delivery_mode=2))
       connection.close()

Use a while loop to update json_message and send json message, but  many error messages are output on the console:

Pika version 1.2.0 connecting to ('192.168.1.51', 5672)

Socket connected: <socket.socket fd=4516, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.1.81', 58025), raddr=('192.168.1.51', 5672)>

Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>).

AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>

AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>

Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>

Created channel=1

Closing connection (200): Normal shutdown

Closing channel (200): 'Normal shutdown' on <Channel number=1 OPEN conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>>

Received <Channel.CloseOk> on <Channel number=1 CLOSING conn=<SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x0000019EB279E670> params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>>

Closing connection (200): 'Normal shutdown'

Aborting transport connection: state=1; <socket.socket fd=4516, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.1.81', 58025), raddr=('192.168.1.51', 5672)>

_AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <socket.socket fd=4516, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.1.81', 58025), raddr=('192.168.1.51', 5672)>

Deactivating transport: state=1; <socket.socket fd=4516, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.1.81', 58025), raddr=('192.168.1.51', 5672)>

AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'

Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'

Closing transport socket and unlinking: state=3; <socket.socket fd=4516, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.1.81', 58025), raddr=('192.168.1.51', 5672)>

User-initiated close: result=BlockingConnection__OnClosedArgs(connection=<SelectConnection CLOSED transport=None params=<ConnectionParameters host=192.168.1.51 port=5672 virtual_host=/ ssl=False>>, error=ConnectionClosedByClient: (200) 'Normal shutdown')

BlockingConnection.close(200, 'Normal shutdown') called on closed connection.   

I don't know how to fix this error. Please help me. Thank you.