diff options
Diffstat (limited to 'weed/messaging/broker/broker_grpc_server_publish.go')
| -rw-r--r-- | weed/messaging/broker/broker_grpc_server_publish.go | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/weed/messaging/broker/broker_grpc_server_publish.go b/weed/messaging/broker/broker_grpc_server_publish.go index 210127be3..985f708b5 100644 --- a/weed/messaging/broker/broker_grpc_server_publish.go +++ b/weed/messaging/broker/broker_grpc_server_publish.go @@ -2,7 +2,6 @@ package broker import ( "io" - "time" "github.com/golang/protobuf/proto" @@ -77,16 +76,9 @@ func (broker *MessageBroker) Publish(stream messaging_pb.SeaweedMessaging_Publis continue } - m := &messaging_pb.Message{ - Timestamp: time.Now().UnixNano(), - Key: in.Data.Key, - Value: in.Data.Value, - Headers: in.Data.Headers, - } - - // fmt.Printf("received: %d : %s\n", len(m.Value), string(m.Value)) + // fmt.Printf("received: %d : %s\n", len(in.Data.Value), string(in.Data.Value)) - data, err := proto.Marshal(m) + data, err := proto.Marshal(in.Data) if err != nil { glog.Errorf("marshall error: %v\n", err) continue |