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