A swift client for interacting with a nats server.
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"]
),
]
)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")Saveconnect_urlsproperty from INFO response and use it later when attempting to reconnectIn(just pass "" as payload)publishmethod make the payload optional. Its ok to send 0 count and no payloadPUB swift.test 0\r\n\r\nSupport subscribing to a queue groupSUB swift.test G1 11\r\nConfigurable max queue size, default 100- Configurable message encoding, default UTF-8
When trying to reconnect to the server, wait 5 seconds between retries, configurableAdd areconnectingevent