libqueue

type IClient interface {
}

type IPubSub interface {
	SetClient(iClient *IClient) IPubSub
	SetChannel(channel string) IPubSub
	Publish(msg string) error
	ReceiveMessage() chan string
	Close() error
}

type IQueue interface {
	SetClient(iClient *IClient) IQueue
	SetTopic(topic string) IQueue
	Enqueue(string) error
	Dequeue() (string, error)
}