mirror of
https://git.mills.io/prologic/msgbus.git
synced 2024-06-16 03:49:03 +00:00
use New instead of NewMessageBus for main message bus constructor (#5)
* use New instead of NewMessageBus for main message bus constructor * update readme: New as message bus constructor
This commit is contained in:
parent
8da5d41e65
commit
22efa3afc8
@ -56,7 +56,7 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
m := msgbus.NewMessageBus()
|
m := msgbus.New()
|
||||||
m.Put("foo", m.NewMessage([]byte("Hello World!")))
|
m.Put("foo", m.NewMessage([]byte("Hello World!")))
|
||||||
|
|
||||||
msg, ok := m.Get("foo")
|
msg, ok := m.Get("foo")
|
||||||
|
@ -142,8 +142,8 @@ type MessageBus struct {
|
|||||||
listeners map[*Topic]*Listeners
|
listeners map[*Topic]*Listeners
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewMessageBus ...
|
// New ...
|
||||||
func NewMessageBus(options *Options) *MessageBus {
|
func New(options *Options) *MessageBus {
|
||||||
var (
|
var (
|
||||||
ttl time.Duration
|
ttl time.Duration
|
||||||
withMetrics bool
|
withMetrics bool
|
||||||
|
@ -7,12 +7,12 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func TestMessageBusLen(t *testing.T) {
|
func TestMessageBusLen(t *testing.T) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
assert.Equal(t, mb.Len(), 0)
|
assert.Equal(t, mb.Len(), 0)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestMessage(t *testing.T) {
|
func TestMessage(t *testing.T) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
assert.Equal(t, mb.Len(), 0)
|
assert.Equal(t, mb.Len(), 0)
|
||||||
|
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
@ -25,7 +25,7 @@ func TestMessage(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestMessageGetEmpty(t *testing.T) {
|
func TestMessageGetEmpty(t *testing.T) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
assert.Equal(t, mb.Len(), 0)
|
assert.Equal(t, mb.Len(), 0)
|
||||||
|
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
@ -35,7 +35,7 @@ func TestMessageGetEmpty(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestMessageBusPutGet(t *testing.T) {
|
func TestMessageBusPutGet(t *testing.T) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
expected := Message{Topic: topic, Payload: []byte("foo")}
|
expected := Message{Topic: topic, Payload: []byte("foo")}
|
||||||
mb.Put(expected)
|
mb.Put(expected)
|
||||||
@ -46,7 +46,7 @@ func TestMessageBusPutGet(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func BenchmarkMessageBusPut(b *testing.B) {
|
func BenchmarkMessageBusPut(b *testing.B) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
msg := Message{Topic: topic, Payload: []byte("foo")}
|
msg := Message{Topic: topic, Payload: []byte("foo")}
|
||||||
b.ResetTimer()
|
b.ResetTimer()
|
||||||
@ -56,7 +56,7 @@ func BenchmarkMessageBusPut(b *testing.B) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func BenchmarkMessageBusGet(b *testing.B) {
|
func BenchmarkMessageBusGet(b *testing.B) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
msg := Message{Topic: topic, Payload: []byte("foo")}
|
msg := Message{Topic: topic, Payload: []byte("foo")}
|
||||||
for i := 0; i < b.N; i++ {
|
for i := 0; i < b.N; i++ {
|
||||||
@ -69,7 +69,7 @@ func BenchmarkMessageBusGet(b *testing.B) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func BenchmarkMessageBusGetEmpty(b *testing.B) {
|
func BenchmarkMessageBusGetEmpty(b *testing.B) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
b.ResetTimer()
|
b.ResetTimer()
|
||||||
for i := 0; i < b.N; i++ {
|
for i := 0; i < b.N; i++ {
|
||||||
@ -78,7 +78,7 @@ func BenchmarkMessageBusGetEmpty(b *testing.B) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func BenchmarkMessageBusPutGet(b *testing.B) {
|
func BenchmarkMessageBusPutGet(b *testing.B) {
|
||||||
mb := NewMessageBus(nil)
|
mb := New(nil)
|
||||||
topic := mb.NewTopic("foo")
|
topic := mb.NewTopic("foo")
|
||||||
msg := Message{Topic: topic, Payload: []byte("foo")}
|
msg := Message{Topic: topic, Payload: []byte("foo")}
|
||||||
b.ResetTimer()
|
b.ResetTimer()
|
||||||
|
Loading…
Reference in New Issue
Block a user