async def ack(self, msg):
ack_proto = protocol.Ack()<EOL>ack_proto.subject = msg.proto.subject<EOL>ack_proto.sequence = msg.proto.sequence<EOL>await self._nc.publish(msg.sub.ack_inbox, ack_proto.SerializeToString())<EOL>
Used to manually acks a message.

:param msg: Message which is pending to be acked by client.