1 17 package org.apache.servicemix.components.pojo; 18 19 import org.apache.servicemix.client.ServiceMixClient; 20 import org.apache.servicemix.jbi.jaxp.StringSource; 21 22 import javax.jbi.messaging.InOnly; 23 import javax.jbi.messaging.MessagingException; 24 import javax.jbi.messaging.NormalizedMessage; 25 26 29 public class PojoSender { 31 private ServiceMixClient client; 32 33 public void sendMessages(int count) throws MessagingException { 34 for (int i = 0; i < count; i++) { 35 InOnly exchange = client.createInOnlyExchange(); 36 NormalizedMessage message = exchange.getInMessage(); 37 38 message.setProperty("id", new Integer (i)); 39 message.setContent(new StringSource("<example id='" + i + "'/>")); 40 41 client.send(exchange); 42 } 43 } 44 45 public ServiceMixClient getClient() { 46 return client; 47 } 48 49 public void setClient(ServiceMixClient client) { 50 this.client = client; 51 } 52 } 53 | Popular Tags |