Documentation
¶
Index ¶
- type RabbitmqClient
- func (r *RabbitmqClient) Close() error
- func (r *RabbitmqClient) CreateChannel() (*amqp.Channel, error)
- func (r *RabbitmqClient) Iterator() (<-chan types.RabbitmqMessage, error)
- func (c *RabbitmqClient) NewSessionFlowClient(sessionID string) *SessionFlowClient
- func (r *RabbitmqClient) Send(sendQueue string, payload interface{}) error
- func (r *RabbitmqClient) SessionKeepRequest(ctx context.Context, sendQueue string, payload interface{}) (types.RabbitmqMessage, error)
- func (r *RabbitmqClient) Stop() error
- type SessionFlowClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitmqClient ¶
type RabbitmqClient struct {
// contains filtered or unexported fields
}
func NewRabbitmqClient ¶
func NewRabbitmqClient(url, queueFrom, queueFromResponse string, queueTo []string, prefetchCount int) (*RabbitmqClient, error)
func NewRabbitmqClientWithConfig ¶
func NewRabbitmqClientWithConfig(config types.RabbitmqConfig) (*RabbitmqClient, error)
func (*RabbitmqClient) Close ¶
func (r *RabbitmqClient) Close() error
func (*RabbitmqClient) CreateChannel ¶
func (r *RabbitmqClient) CreateChannel() (*amqp.Channel, error)
func (*RabbitmqClient) Iterator ¶
func (r *RabbitmqClient) Iterator() (<-chan types.RabbitmqMessage, error)
func (*RabbitmqClient) NewSessionFlowClient ¶
func (c *RabbitmqClient) NewSessionFlowClient(sessionID string) *SessionFlowClient
func (*RabbitmqClient) Send ¶
func (r *RabbitmqClient) Send(sendQueue string, payload interface{}) error
func (*RabbitmqClient) SessionKeepRequest ¶
func (r *RabbitmqClient) SessionKeepRequest(ctx context.Context, sendQueue string, payload interface{}) (types.RabbitmqMessage, error)
func (*RabbitmqClient) Stop ¶
func (r *RabbitmqClient) Stop() error
type SessionFlowClient ¶
type SessionFlowClient struct {
// contains filtered or unexported fields
}
func (*SessionFlowClient) Send ¶
func (c *SessionFlowClient) Send(sendQueue string, payload interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.