Skip to content

Exhook new return type #35

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: for-emqx-v5.4
Choose a base branch
from
Open

Exhook new return type #35

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
5a379bd
feat(v54): feats and fix for 5.4
JimMoen Nov 30, 2023
8fb96d7
fix: rm src file `exhook.pb.go` and `exhook_grpc.pb.go`
JimMoen Nov 30, 2023
284f541
feat(exhook): use 'STOP_AND_REPUBLISH' to allow msg processed by rule…
JimMoen Dec 1, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 8 additions & 2 deletions exhook-svr-erlang/apps/exhook_svr/priv/exhook.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
//------------------------------------------------------------------------------
// Copyright (c) 2020-2022 EMQ Technologies Co., Ltd. All Rights Reserved.
// Copyright (c) 2020-2023 EMQ Technologies Co., Ltd. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -294,6 +294,9 @@ message ValuedResponse {
IGNORE = 1;

STOP_AND_RETURN = 2;

// Republish message, used on the 'message.publish' hook
STOP_AND_REPUBLISH = 3;
}

ResponsedType type = 1;
Expand Down Expand Up @@ -460,8 +463,11 @@ message SubOpts {
// The QoS level
uint32 qos = 1;

// deprecated
reserved 2;
reserved "share";
// The group name for shared subscription
string share = 2;
// string share = 2;

// The Retain Handling option (MQTT v5.0)
//
Expand Down
2 changes: 2 additions & 0 deletions exhook-svr-go/.gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
/protobuf/exhook.pb.go
/protobuf/exhook_grpc.pb.go
Loading