| | |
| | | /** |
| | | * 处理类在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; |
| | | } |
| | | } |