1 46 50 package org.mr.kernel.services.queues; 51 52 import org.mr.MantaAgent; 53 import org.mr.kernel.services.ServiceActor; 54 import org.mr.kernel.services.ServiceConsumer; 55 import org.mr.core.protocol.MantaBusMessage; 56 import org.mr.core.protocol.MantaBusMessageConsts; 57 58 66 public class QueueReceiver { 67 68 private ServiceConsumer consumer; 69 private long numberOfReceive; 70 71 72 public QueueReceiver(ServiceConsumer consumer, long numberOfReceive){ 73 this.consumer = consumer; 74 this.numberOfReceive = numberOfReceive; 75 76 } 78 79 public void receive(MantaBusMessage msg ){ 80 numberOfReceive --; 81 82 msg.setRecipient(consumer); 83 msg.addHeader(MantaBusMessageConsts.HEADER_NAME_LOGICAL_DESTINATION ,consumer.getServiceName()+consumer.getId() ); 84 85 86 MantaAgent.getInstance().send(msg, (ServiceActor)msg.getSource()); 87 88 } 89 90 91 92 95 public ServiceConsumer getConsumer() { 96 return consumer; 97 } 98 99 100 101 104 public long getNumberOfReceive() { 105 return numberOfReceive; 106 } 107 108 111 public void setNumberOfReceive(long numberOfReceive) { 112 this.numberOfReceive = numberOfReceive; 113 } 114 115 116 } 117 | Popular Tags |