package messenger

import (
	"context"
	"gitee.com/anesec/chameleon/apis"
)

func newKafka(options *messengerOptions) (Messenger, error) {
	return &kafka{}, nil
}

type kafka struct {
}

func (msgr *kafka) Name() string {
	return Kafka
}

func (msgr *kafka) Messages(ctx context.Context, options ...FetchOption) (<-chan *apis.Message, <-chan error) {
	return nil, nil
}

func (msgr *kafka) Write(ctx context.Context, msg *apis.Message, options ...WriteOption) error {
	return nil
}

func (msgr *kafka) Close() error {
	return nil
}