Skip to content

An Arduino / ESP8266 / Particle Photon compatible C++ library for communicating with a NATS (http://nats.io) server

License

Notifications You must be signed in to change notification settings

isobit/arduino-nats

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

48 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

NATS - Arduino Client

An Arduino / Spark Core / Particle Photon compatible C++ library for communicating with a NATS server.

Features

  • Header-only library
  • Compatible with Ethernet and WiFi-cabable Arduinos, Particle Photon / Spark Core devices, and even the ESP8266 (if using the Arduino extension)
  • Familiar C++ object-oriented API, similar usage to the official NATS client APIs
  • Automatically attempts to reconnect to NATS server if the connection is dropped

Installation

platformio lib install ArduinoNATS

Arduino IDE

Download a zip from the latest release and add it via Sketch > Include Library > Add .ZIP Library.

Manual

Just download ArduinoNATS.h and include it in your main ino file.

API

class NATS {
	typedef struct {
		const char* subject;
		const int sid;
		const char* reply;
		const char* data;
		const int size;
	} msg;

	typedef void (*sub_cb)(msg e);
	typedef void (*event_cb)();

	NATS(
		Client* client,
		const char* hostname,
		int port = NATS_DEFAULT_PORT,
		const char* user = NULL,
		const char* pass = NULL
	);

	bool connect();			// initiate the connection
	void disconnect();      // close the connection

	bool connected;			// whether or not the client is connected

	int max_outstanding_pings;	// number of outstanding pings to allow before considering the connection closed (default 3)
	int max_reconnect_attempts; // number of times to attempt reconnects, -1 means no maximum (default -1)

	event_cb on_connect;    // called after NATS finishes connecting to server
	event_cb on_disconnect; // called when a disconnect happens
	event_cb on_error;		// called when an error is received

	void publish(const char* subject, const char* msg = NULL, const char* replyto = NULL);
	void publish(const char* subject, const bool msg);
	void publishf(const char* subject, const char* fmt, ...);

	int subscribe(const char* subject, sub_cb cb, const char* queue = NULL, const int max_wanted = 0);
	void unsubscribe(const int sid);

	int request(const char* subject, const char* msg, sub_cb cb, const int max_wanted = 1);

	void process();			// process pending messages from the buffer, must be called regularly in loop()
}

About

An Arduino / ESP8266 / Particle Photon compatible C++ library for communicating with a NATS (http://nats.io) server

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Contributors 4

  •  
  •  
  •  
  •  

Languages