README
¶
lb-stomp
Load-balanced Stomp (lb-stomp) package provides load-balanced interface to Stomp AMQ brokers.
Built and test code:
go build
go test
Example how to use it
import stomp "github.com/vkuznet/lb-stomp"
// create new manager
config := stomp.Config{StompURI: "abc:123", StompLogin: "test", StompPassword: "test"}
mgr := stomp.New(config)
data := `{"test": 1}`
err := stomp.Send([]byte(data))
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
URI string `json:"uri"` // Stomp AMQ URI
Login string `json:"login"` // Stomp AQM login name
Password string `json:"password"` // Stomp AQM password
Iterations int `json:"iterations"` // Stomp iterations
SendTimeout int `json:"sendTimeout"` // heartbeat send timeout
RecvTimeout int `json:"recvTimeout"` // heartbeat recv timeout
HeartBeatGracePeriod float64 `json:"heartBeatGracePeriod"` // is used to calculate the read heart-beat timeout
Endpoint string `json:"endpoint"` // StompAMQ endpoint
ContentType string `json:"contentType"` // ContentType of UDP packet
Protocol string `json:"protocol"` // network protocol to use
Verbose int `json:"verbose"` // verbosity level
}
Config stores server configuration parameters
type StompManager ¶
type StompManager struct {
Addresses []string // stomp addresses
ConnectionPool []*stomp.Conn // pool of connections to stomp AMQ Broker
Config Config // stomp configuration
}
StompManager hanles connection to Stomp AMQ Broker
func (*StompManager) GetConnection ¶ added in v0.0.4
func (s *StompManager) GetConnection() (*stomp.Conn, string, error)
get new stomp connection
func (*StompManager) ResetConnection ¶ added in v0.0.4
func (s *StompManager) ResetConnection()
reset all stomp connections
func (*StompManager) String ¶
func (s *StompManager) String() string
String represents Stomp Manager
Source Files
Click to show internal directories.
Click to hide internal directories.