Documentation
¶
Overview ¶
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumeMessageContext ¶
type ConsumeMessageHook ¶
type ConsumeMessageHook interface {
HookName() string
ConsumeMessageBefore(context *ConsumeMessageContext)
ConsumeMessageAfter(context *ConsumeMessageContext)
}
ConsumeMessageHook 消费消息回调 Author rongzhihong Since 2017/9/5
type SendMessageContext ¶
type SendMessageContext struct {
ProducerGroup string
Topic string
MsgId string
OriginMsgId string
QueueId int32
QueueOffset int64
BrokerAddr string
BornHost string
BodyLength int
Code int
ErrorMsg string
MsgProps string
}
SendMessageContext 消息发送上下文 Author gaoyanlei Since 2017/8/15
func NewSendMessageContext ¶
func NewSendMessageContext() *SendMessageContext
NewSendMessageContext 初始化 Author gaoyanlei Since 2017/8/15
type SendMessageHook ¶
type SendMessageHook interface {
HookName() string
SendMessageBefore(context *SendMessageContext)
SendMessageAfter(context *SendMessageContext)
}
SendMessageHook 发送消息回调 Author rongzhihong Since 2017/9/5
Source Files