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
Click to show internal directories.
Click to hide internal directories.