Versions in this module Expand all Collapse all v0 v0.1.0 Aug 5, 2025 Changes in this version + func MessageToPayload(msg *Message) ([]byte, error) + type AMQFactory struct + func (f *AMQFactory) Create(config Config) (MessageQueue, error) + type AMQMessageQueue struct + func NewAMQMessageQueue(config Config) (*AMQMessageQueue, error) + func (mq *AMQMessageQueue) Close() error + func (mq *AMQMessageQueue) CreateQueue(ctx context.Context, name string) error + func (mq *AMQMessageQueue) DeleteQueue(ctx context.Context, name string) error + func (mq *AMQMessageQueue) GetAsyncConsumer(agentID string, metadata map[string]string) (client.AsyncConsumer, error) + func (mq *AMQMessageQueue) GetClient(agentID string, metadata map[string]string) (client.Client, error) + func (mq *AMQMessageQueue) GetQueueStats(ctx context.Context, queueName string) (*types.QueueStats, error) + func (mq *AMQMessageQueue) ListQueues(ctx context.Context) ([]*types.Queue, error) + func (mq *AMQMessageQueue) PublishTask(ctx context.Context, from, topic string, message *Message) error + func (mq *AMQMessageQueue) SendMessage(ctx context.Context, from, to string, message *Message) error + type Config struct + MessageTimeout int + StorePath string + WorkerPoolSize int + type Factory interface + Create func(config Config) (MessageQueue, error) + type Message struct + From string + ID string + Payload map[string]interface{} + Timestamp int64 + To string + Topic string + Type string + func PayloadToMessage(payload []byte) (*Message, error) + type MessageHandler func(ctx context.Context, msg *Message) error + type MessageQueue interface + Close func() error + CreateQueue func(ctx context.Context, name string) error + DeleteQueue func(ctx context.Context, name string) error + GetAsyncConsumer func(agentID string, metadata map[string]string) (client.AsyncConsumer, error) + GetClient func(agentID string, metadata map[string]string) (client.Client, error) + GetQueueStats func(ctx context.Context, queueName string) (*types.QueueStats, error) + ListQueues func(ctx context.Context) ([]*types.Queue, error) + PublishTask func(ctx context.Context, from, topic string, message *Message) error + SendMessage func(ctx context.Context, from, to string, message *Message) error
Go to main page