messagequeue

type AMQFactory struct{}

type AMQMessageQueue struct {
	// contains filtered or unexported fields
}

type Config struct {
	StorePath      string // Path for BadgerDB storage
	WorkerPoolSize int    // Number of workers per queue
	MessageTimeout int    // Message timeout in seconds
}

type Factory interface {
	Create(config Config) (MessageQueue, error)
}

type Message struct {
	ID        string                 `json:"id"`
	Topic     string                 `json:"topic"`
	From      string                 `json:"from"`         // Agent ID
	To        string                 `json:"to,omitempty"` // Agent ID or empty for broadcast
	Type      string                 `json:"type"`
	Payload   map[string]interface{} `json:"payload"`
	Timestamp int64                  `json:"timestamp"`
}

type MessageHandler func(ctx context.Context, msg *Message) error

type MessageQueue interface {
	// GetClient returns an AMQ client for an agent
	GetClient(agentID string, metadata map[string]string) (client.Client, error)

	// GetAsyncConsumer returns an async consumer for an agent
	GetAsyncConsumer(agentID string, metadata map[string]string) (client.AsyncConsumer, error)

	// CreateQueue creates a new queue/topic
	CreateQueue(ctx context.Context, name string) error

	// DeleteQueue removes a queue/topic
	DeleteQueue(ctx context.Context, name string) error

	// SendMessage sends a message directly between agents
	SendMessage(ctx context.Context, from, to string, message *Message) error

	// PublishTask publishes a task to a topic
	PublishTask(ctx context.Context, from, topic string, message *Message) error

	// GetQueueStats returns queue statistics
	GetQueueStats(ctx context.Context, queueName string) (*types.QueueStats, error)

	// ListQueues returns all queues
	ListQueues(ctx context.Context) ([]*types.Queue, error)

	// Close closes the message queue connection
	Close() error
}