messaging

package

v0.2.1 Latest Latest Go to latest Published: Oct 25, 2016 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Nats struct {
	URL string
	// contains filtered or unexported fields
}

Nats singleton

func (Nats *Nats) Close() error

Close nats

func (Nats *Nats) Connect() error

Connect to Nats

func (Nats *Nats) Publish(subject string, data []byte) (string, error)

Publish a message asynchronously