public class ProducerInterceptorAdapter extends Object implements ProducerInterceptor
| 构造器和说明 |
|---|
ProducerInterceptorAdapter(io.openmessaging.interceptor.ProducerInterceptor omsProducerInterceptor) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
equals(Object obj) |
io.openmessaging.interceptor.ProducerInterceptor |
getOmsProducerInterceptor() |
protected io.openmessaging.interceptor.Context |
getOrCreateOMSContext(ProduceContext context) |
int |
hashCode() |
void |
postSend(ProduceContext context,
List<SendResult> result) |
boolean |
preSend(ProduceContext context) |
String |
toString() |
public ProducerInterceptorAdapter(io.openmessaging.interceptor.ProducerInterceptor omsProducerInterceptor)
public boolean preSend(ProduceContext context)
preSend 在接口中 ProducerInterceptorpublic void postSend(ProduceContext context, List<SendResult> result)
postSend 在接口中 ProducerInterceptorprotected io.openmessaging.interceptor.Context getOrCreateOMSContext(ProduceContext context)
public io.openmessaging.interceptor.ProducerInterceptor getOmsProducerInterceptor()
Copyright © 2020 Joyqueue Community. All rights reserved.