[skywalking-banyandb] branch main updated: Init local pipeline

[hanahmily]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git


The following commit(s) were added to refs/heads/main by this push:
     new 199c1b0  Init local pipeline
199c1b0 is described below

commit 199c1b0334b8cf4851fe1f1e8b0ebd2bf3f665db
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Thu Aug 5 21:04:09 2021 +0800

    Init local pipeline
    
    Signed-off-by: Gao Hongtao <hanahm...@gmail.com>
---
 banyand/queue/queue.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/banyand/queue/queue.go b/banyand/queue/queue.go
index 57c7b37..a39f494 100644
--- a/banyand/queue/queue.go
+++ b/banyand/queue/queue.go
@@ -32,5 +32,8 @@ type Queue interface {
 }
 
 func NewQueue(_ context.Context, repo discovery.ServiceRepo) (Queue, error) {
-       return &local{repo: repo}, nil
+       return &local{
+               repo:  repo,
+               local: bus.NewBus(),
+       }, nil
 }