aboutsummaryrefslogtreecommitdiff
path: root/weed/messaging/broker/broker_grpc_server_publish.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/messaging/broker/broker_grpc_server_publish.go')
-rw-r--r--weed/messaging/broker/broker_grpc_server_publish.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/messaging/broker/broker_grpc_server_publish.go b/weed/messaging/broker/broker_grpc_server_publish.go
index 89c568b0d..210127be3 100644
--- a/weed/messaging/broker/broker_grpc_server_publish.go
+++ b/weed/messaging/broker/broker_grpc_server_publish.go
@@ -23,7 +23,7 @@ func (broker *MessageBroker) Publish(stream messaging_pb.SeaweedMessaging_Publis
// TODO look it up
topicConfig := &messaging_pb.TopicConfiguration{
-
+ IsTransient: true,
}
// send init response