Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPClient ¶
type AMQPClient struct {
// contains filtered or unexported fields
}
func NewAMQPClient ¶
func NewAMQPClient(broker, username, password string) (*AMQPClient, error)
func (*AMQPClient) Disconnect ¶
func (a *AMQPClient) Disconnect()
type ActiveMQApi ¶
type MQTTClient ¶
type MQTTClient struct {
// contains filtered or unexported fields
}
func NewMQTTClient ¶
func NewMQTTClient(broker, username, password string) (*MQTTClient, error)
func (*MQTTClient) Disconnect ¶
func (m *MQTTClient) Disconnect()
type MockActiveMQApi ¶
MockActiveMQApi is an autogenerated mock type for the ActiveMQApi type
func NewMockActiveMQApi ¶ added in v0.2.3
func NewMockActiveMQApi(t interface {
mock.TestingT
Cleanup(func())
}) *MockActiveMQApi
NewMockActiveMQApi creates a new instance of MockActiveMQApi. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockActiveMQApi) Disconnect ¶
func (_m *MockActiveMQApi) Disconnect()
Disconnect provides a mock function with given fields:
type StompClient ¶
type StompClient struct {
// contains filtered or unexported fields
}
func NewStompClient ¶
func NewStompClient(broker, username, password string) *StompClient
func (*StompClient) Connect ¶ added in v0.2.3
func (s *StompClient) Connect() error
Connect connets client to broker
func (*StompClient) Disconnect ¶
func (s *StompClient) Disconnect()
Disconnect closes connection to broker
Source Files
Click to show internal directories.
Click to hide internal directories.