| | |
|---|
| | | /** |
|---|
| | | * 处理类在spring中的bean名称 |
|---|
| | | */ |
|---|
| | | private com.matrix.core.rabbitmq.DeliverCallbackAdapter handerAdapter; |
|---|
| | | private DeliverCallbackAdapter handerAdapter; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 自动确认 默认为true |
|---|
| | |
|---|
| | | this.queue = queue; |
|---|
| | | this.routingKey = routingKey; |
|---|
| | | if(hander!=null){ |
|---|
| | | this.handerAdapter = new com.matrix.core.rabbitmq.DeliverCallbackAdapter(hander,routingKey); |
|---|
| | | this.handerAdapter = new DeliverCallbackAdapter(hander,routingKey); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | |
|---|
| | | this.queue = queue; |
|---|
| | | this.routingKey = routingKey; |
|---|
| | | if(hander!=null){ |
|---|
| | | this.handerAdapter = new com.matrix.core.rabbitmq.DeliverCallbackAdapter(hander,routingKey); |
|---|
| | | this.handerAdapter = new DeliverCallbackAdapter(hander,routingKey); |
|---|
| | | } |
|---|
| | | this.autoAck=autoAck; |
|---|
| | | |
|---|
| | |
|---|
| | | return handerAdapter; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void setHander(com.matrix.core.rabbitmq.DeliverCallbackAdapter hander) { |
|---|
| | | public void setHander(DeliverCallbackAdapter hander) { |
|---|
| | | this.handerAdapter = hander; |
|---|
| | | } |
|---|
| | | } |
|---|
