Skip to content
A swift client for interacting with NATS servers
Swift
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
Sources/SwiftyNats
SwiftyNats.xcodeproj
Tests
.gitignore
.travis.yml
Dockerfile
LICENSE
Package.swift
README.md

README.md

SwiftyNats

A swift client for interacting with a nats server.

Build Status License Swift4

Installation

Only uses SPM to install. Add the dependencies like below.

// swift-tools-version:4.0

import PackageDescription

let package = Package(
    name: "YourApp",
    products: [
        .library(name: "YourApp", targets: ["YourApp"])
    ],
    dependencies: [
        .package(url: "https://github.com/raykrow/swifty-nats.git", from: "1.0.0")
    ],
    targets: [
        .target(
            name: "YourApp",
            dependencies: ["SwiftyClient"]
        ),
    ]
)

Basic Usage

import SwiftyNats

let client = NatsClient("http://nats.server:4222")

client.on(.connect) { _ in
    print("Client connected")
}

try? client.connect()

client.subscribe("foo.bar") { message in
    print("payload: \(message.payload)")
    print("size: \(message.byteCount)")
    print("reply subject: \(message.replySubject.subject)")
}

client.publish("this event happened", to: "foo.bar")

TODO

  • Save connect_urls property from INFO response and use it later when attempting to reconnect
  • In publish method make the payload optional. Its ok to send 0 count and no payload PUB swift.test 0\r\n\r\n (just pass "" as payload)
  • Support subscribing to a queue group SUB swift.test G1 11\r\n
  • Configurable max queue size, default 100
  • Configurable message encoding, default UTF-8
  • When trying to reconnect to the server, wait 5 seconds between retries, configurable
  • Add a reconnecting event
You can’t perform that action at this time.