nats-io/nats.py v2.12.0

Release v2.12.0

on GitHub

Added

• Add options to send custom WebSocket headers on connect

  custom_headers = {
      "Authorization": ["Bearer MySecretToken"],
      "X-Client-ID": ["my-client-123"],
      "Accept": ["application/json", "text/plain"]
  }
  
  nc = await nats.connect(
      "ws://localhost:4222",
      ws_connection_headers=custom_headers
  )

Fixed

• Fix filter_subject overriding filter_subjects #711
• Fix EOF processing while client is connecting #719
• Fix error when closing ws transport
• Fix test_object_list #728

Improved

• Add consumer pause/resume support #761
• Add time field to RawStreamMsg
• Add allow_msg_schedules to StreamConfig #765
• Add per-message TTL support #763
• Add allow_batch to StreamConfig #764
• Add test for direct get returning no responders #767